Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 54 for unbuffered (0.06 sec)

  1. doc/go1.17_spec.html

    make(chan int, 100)
    </pre>
    
    <p>
    The capacity, in number of elements, sets the size of the buffer in the channel.
    If the capacity is zero or absent, the channel is unbuffered and communication
    succeeds only when both a sender and receiver are ready. Otherwise, the channel
    is buffered and communication succeeds without blocking if the buffer
    is not full (sends) or not empty (receives).
    A <code>nil</code> channel is never ready for communication.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 10 18:25:45 UTC 2024
    - 211.6K bytes
    - Viewed (0)
  2. doc/go_spec.html

    make(chan int, 100)
    </pre>
    
    <p>
    The capacity, in number of elements, sets the size of the buffer in the channel.
    If the capacity is zero or absent, the channel is unbuffered and communication
    succeeds only when both a sender and receiver are ready. Otherwise, the channel
    is buffered and communication succeeds without blocking if the buffer
    is not full (sends) or not empty (receives).
    A <code>nil</code> channel is never ready for communication.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 00:58:01 UTC 2024
    - 282.5K bytes
    - Viewed (0)
  3. src/bufio/bufio.go

    	return NewReaderSize(rd, defaultBufSize)
    }
    
    // Size returns the size of the underlying buffer in bytes.
    func (b *Reader) Size() int { return len(b.buf) }
    
    // Reset discards any buffered data, resets all state, and switches
    // the buffered reader to read from r.
    // Calling Reset on the zero value of [Reader] initializes the internal buffer
    // to the default size.
    // Calling b.Reset(b) (that is, resetting a [Reader] to itself) does nothing.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  4. internal/deadlineconn/deadlineconn.go

    package deadlineconn
    
    import (
    	"net"
    	"time"
    )
    
    const updateInterval = 250 * time.Millisecond
    
    // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout.
    type DeadlineConn struct {
    	net.Conn
    	readDeadline  time.Duration // sets the read deadline on a connection.
    	readSetAt     time.Time
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 17:40:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

       * Prepares the HTTP headers and sends them to the server.
       *
       * For streaming requests with a body, headers must be prepared **before** the output stream has
       * been written to. Otherwise the body would need to be buffered!
       *
       * For non-streaming requests with a body, headers must be prepared **after** the output stream
       * has been written to and closed. This ensures that the `Content-Length` header field receives
       * the proper value.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  6. mockwebserver/src/main/kotlin/mockwebserver3/Stream.kt

      val requestBody: BufferedSource
      val responseBody: BufferedSink
    
      /**
       * Terminate the stream so that no further data is transmitted or received. Note that
       * [requestBody] may return data after this call; that is the buffered data received before this
       * stream was canceled.
       *
       * This does nothing if [requestBody] and [responseBody] are already closed.
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  7. guava/src/com/google/common/io/ByteSink.java

       *
       * @throws IOException if an I/O error occurs while opening the stream
       */
      public abstract OutputStream openStream() throws IOException;
    
      /**
       * Opens a new buffered {@link OutputStream} for writing to this sink. The returned stream is not
       * required to be a {@link BufferedOutputStream} in order to allow implementations to simply
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 28 16:55:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. src/main/java/jcifs/SmbWatchHandle.java

         * 
         * Closing the context should cancel a pending notify request, but that does not seem to work reliable in all
         * implementations.
         * 
         * Changes in between these calls (as long as the file is open) are buffered by the server, so iteratively calling
         * this method should provide all changes (size of that buffer can be adjusted through
         * {@link jcifs.Configuration#getNotifyBufferSize()}).
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.3K bytes
    - Viewed (0)
  9. internal/ringbuffer/README.md

    If you want to block when reading or writing, you must enable it:
    
    ```go
    	rb := ringbuffer.New(1024).SetBlocking(true)
    ```
    
    Enabling blocking will cause the ring buffer to behave like a buffered [io.Pipe](https://pkg.go.dev/io#Pipe).
    
    Regular Reads will block until data is available, but not wait for a full buffer. 
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  10. src/bufio/bufio_test.go

    		t.Error("expected flush error, got nil")
    	}
    	if _, err := wr.ReadFrom(strings.NewReader("test2")); err == nil {
    		t.Fatal("expected error, got nil")
    	}
    	if buffered := wr.Buffered(); buffered != wantBuffered {
    		t.Fatalf("Buffered = %v; want %v", buffered, wantBuffered)
    	}
    }
    
    func BenchmarkReaderCopyOptimal(b *testing.B) {
    	// Optimal case is where the underlying reader implements io.WriterTo
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
Back to top