Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 375 for jstream (0.53 sec)

  1. src/test/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGeneratorTest.java

     */
    package org.codelibs.fess.thumbnail.impl;
    
    import java.awt.image.BufferedImage;
    import java.io.File;
    import java.io.IOException;
    
    import javax.imageio.ImageIO;
    import javax.imageio.stream.ImageInputStream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.unit.UnitFessTestCase;
    
    public class HtmlTagBasedGeneratorTest extends UnitFessTestCase {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. docs/erasure/storage-class/README.md

    objectStat, err := object.Stat()
    if err != nil {
     log.Fatalln(err)
    }
    
    n, err := s3Client.PutObject("my-bucketname", "my-objectname", object, objectStat.Size(), minio.PutObjectOptions{ContentType: "application/octet-stream", StorageClass: "REDUCED_REDUNDANCY"})
    if err != nil {
     log.Fatalln(err)
    }
    log.Println("Uploaded", "my-objectname", " of size: ", n, "Successfully.")
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 15 23:04:20 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  3. internal/ringbuffer/README.md

    Writes will block until there is space available and writes bigger than the buffer will wait for reads to make space.
    
    `TryRead` and `TryWrite` are still available for non-blocking reads and writes.
    
    To signify the end of the stream, close the ring buffer from the writer side with `rb.CloseWriter()`
    
    Either side can use `rb.CloseWithError(err error)` to signal an error and close the ring buffer. 
    Any reads or writes will return the error on next call.
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  4. internal/bucket/lifecycle/tag.go

    )
    
    // UnmarshalXML - decodes XML data.
    func (tag *Tag) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	var keyAlreadyParsed, valueAlreadyParsed bool
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			var s string
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/curl/CurlResponse.java

        }
    
        public void setHeaders(final Map<String, List<String>> headers) {
            if (headers != null) {
                final Map<String, List<String>> map = new HashMap<>();
                headers.entrySet().stream().filter(e -> e.getKey() != null)
                        .forEach(e -> map.put(e.getKey().toLowerCase(Locale.ROOT), e.getValue()));
                this.headers = map;
            }
        }
    
    Registered: Sun Oct 27 04:35:21 UTC 2024
    - Last Modified: Mon Nov 14 21:05:19 UTC 2022
    - 4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/admin/upgrade/AdminUpgradeAction.java

    import java.io.IOException;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.stream.StreamUtil;
    import org.codelibs.curl.CurlResponse;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.annotation.Secured;
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 54K bytes
    - Viewed (0)
  7. cmd/object-multipart-handlers.go

    	case authTypeStreamingSigned, authTypeStreamingSignedTrailer:
    		// Initialize stream signature verifier.
    		reader, s3Error = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer)
    		if s3Error != ErrNone {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    			return
    		}
    	case authTypeStreamingUnsignedTrailer:
    		// Initialize stream signature verifier.
    		reader, s3Error = newUnsignedV4ChunkedReader(r, true)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/helper/QueryHelperTest.java

            if (highlightedQuerySet != null) {
                assertEquals(highlightedQuerySet.stream().sorted().collect(Collectors.joining("\n")),
                        set.stream().sorted().collect(Collectors.joining("\n")));
            }
            set.clear();
        }
    
        private void assertFieldLogs(Map<String, List<String>> fieldLogMap) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Jul 11 08:26:36 UTC 2024
    - 39.8K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/RelatedContentHelper.java

            });
        }
    
        @Override
        public int load() {
            final Map<String, Pair<Map<String, String>, List<Pair<Pattern, String>>>> relatedContentMap = new HashMap<>();
            getAvailableRelatedContentList().stream().forEach(entity -> {
                final String key = getHostKey(entity);
                Pair<Map<String, String>, List<Pair<Pattern, String>>> pair = relatedContentMap.get(key);
                if (pair == null) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  10. cmd/test-utils_test.go

    		signature = hex.EncodeToString(sumHMAC(signingKey, []byte(stringToSign)))
    
    		stream = append(stream, []byte(fmt.Sprintf("%x", n)+";chunk-signature="+signature+"\r\n")...)
    		stream = append(stream, buffer[:n]...)
    		stream = append(stream, []byte("\r\n")...)
    
    		if n <= 0 {
    			break
    		}
    
    	}
    	req.Body = io.NopCloser(bytes.NewReader(stream))
    	return req, nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
Back to top