Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 300 for reader_r (0.07 sec)

  1. docs/changelogs/changelog_2x.md

        return such malformed responses will now trigger a `ProtocolException` in
        the client.
    
     *  **WebSocketListener has incompatible changes.** The `onOpen()` method is now
        called on the reader thread, so implementations must return before further
        websocket messages will be delivered. The `onFailure()` method now includes
        an HTTP response if one was returned.
    
    ## Version 2.4.0-RC1
    
    _2015-05-16_
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 26.6K bytes
    - Viewed (0)
  2. internal/s3select/csv/reader_contrib_test.go

    				CommentCharacter:           defaultCommentCharacter,
    				AllowQuotedRecordDelimiter: false,
    				unmarshaled:                true,
    			}
    			if !c.header {
    				args.FileHeaderInfo = none
    			}
    			inr := io.Reader(bytes.NewReader(input))
    			if c.sendErr != nil {
    				inr = io.MultiReader(inr, errReader{c.sendErr})
    			}
    			r, _ := NewReader(io.NopCloser(inr), &args)
    			fields := 0
    			for {
    				record, err = r.Read(record)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 38.5K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    // Errors are ignored, only errors from the callback are returned.
    // For now only direct file paths are supported.
    func (z *erasureServerPools) GetRawData(ctx context.Context, volume, file string, fn func(r io.Reader, host string, disk string, filename string, info StatInfo) error) error {
    	found := 0
    	for _, s := range z.serverPools {
    		for _, set := range s.sets {
    			for _, disk := range set.getDisks() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Futures.java

        }
      }
    
      /**
       * Returns the result of the input {@code Future}, which must have already completed.
       *
       * <p>The benefits of this method are twofold. First, the name "getDone" suggests to readers that
       * the {@code Future} is already done. Second, if buggy code calls {@code getDone} on a {@code
       * Future} that is still pending, the program will throw instead of block. This can be important
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  5. common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto

      // empty there is no information available.
      // +optional
      optional string reason = 1;
    
      // A human-readable description of the cause of the error.  This field may be
      // presented as-is to a reader.
      // +optional
      optional string message = 2;
    
      // The field of the resource that has caused this error, as named by its JSON
      // serialization. May include dot and postfix notation for nested attributes.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  6. api/go1.16.txt

    pkg html/template, func ParseFS(fs.FS, ...string) (*Template, error)
    pkg html/template, method (*Template) ParseFS(fs.FS, ...string) (*Template, error)
    pkg io, func NopCloser(Reader) ReadCloser
    pkg io, func ReadAll(Reader) ([]uint8, error)
    pkg io, type ReadSeekCloser interface { Close, Read, Seek }
    pkg io, type ReadSeekCloser interface, Close() error
    pkg io, type ReadSeekCloser interface, Read([]uint8) (int, error)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 02 16:30:41 UTC 2022
    - 479.2K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v2.go

    	}
    }
    
    // readXLMetaNoData will load the metadata, but skip data segments.
    // This should only be used when data is never interesting.
    // If data is not xlv2, it is returned in full.
    func readXLMetaNoData(r io.Reader, size int64) ([]byte, error) {
    	initial := size
    	hasFull := true
    	if initial > metaDataReadDefault {
    		initial = metaDataReadDefault
    		hasFull = false
    	}
    
    	buf := metaDataPoolGet()[:initial]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
  8. guava/src/com/google/common/collect/MapMakerInternalMap.java

           * about one-sixth of them need cloning when a table doubles. The nodes they replace will be
           * garbage collectable as soon as they are no longer referenced by any reader thread that may
           * be in the midst of traversing table right now.
           */
    
          int newCount = count;
          AtomicReferenceArray<E> newTable = newEntryArray(oldCapacity << 1);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  9. okhttp/api/okhttp.api

    	public fun <init> ()V
    	public final fun byteStream ()Ljava/io/InputStream;
    	public final fun byteString ()Lokio/ByteString;
    	public final fun bytes ()[B
    	public final fun charStream ()Ljava/io/Reader;
    	public fun close ()V
    	public abstract fun contentLength ()J
    	public abstract fun contentType ()Lokhttp3/MediaType;
    	public static final fun create (Ljava/lang/String;Lokhttp3/MediaType;)Lokhttp3/ResponseBody;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:41:01 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

           * about one-sixth of them need cloning when a table doubles. The nodes they replace will be
           * garbage collectable as soon as they are no longer referenced by any reader thread that may
           * be in the midst of traversing table right now.
           */
    
          int newCount = count;
          AtomicReferenceArray<E> newTable = newEntryArray(oldCapacity << 1);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
Back to top