Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 42 for unbuffered (0.1 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

         * this snapshot was created or if another edit is in progress.
         */
        @Throws(IOException::class)
        fun edit(): Editor? = ******@****.***(key, sequenceNumber)
    
        /** Returns the unbuffered stream with the value for [index]. */
        fun getSource(index: Int): Source = sources[index]
    
        /** Returns the byte length of the value for [index]. */
        fun getLength(index: Int): Long = lengths[index]
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt

        while (payload.completeSegmentByteCount() <= PAYLOAD_BYTE_MAX) {
          payload.writeByte('0'.code)
        }
        serverWriter.writeMessageFrame(OPCODE_BINARY, payload.snapshot())
    
        // Write directly to the unbuffered sink. This ensures it will become single frame.
        assertData("827e") // 'e' == 4-byte follow-up length.
        assertData(format("%04X", payload.completeSegmentByteCount()))
        assertData(payload.readByteString())
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  3. internal/grid/grid_test.go

    		}
    		t.Log("client after", time.Since(clientEnd))
    	}
    	// local to remote, unbuffered
    	t.Run("unbuffered", func(t *testing.T) {
    		testHandler(t, handlerTest, false)
    	})
    	t.Run("buffered", func(t *testing.T) {
    		testHandler(t, handlerTest2, false)
    	})
    	t.Run("buffered", func(t *testing.T) {
    		testHandler(t, handlerTest2, true)
    	})
    }
    
    // testStreamDeadline will test if server
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  4. doc/go_mem.html

    yields a program with the same guaranteed behavior.
    </p>
    
    <p class="rule">
    A receive from an unbuffered channel is synchronized before the completion of
    the corresponding send on that channel.
    </p>
    
    <p>
    This program (as above, but with the send and receive statements swapped and
    using an unbuffered channel):
    </p>
    
    <pre>
    var c = make(chan int)
    var a string
    
    func f() {
    	a = "hello, world"
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  5. src/builtin/builtin.go

    //	a small starting size is allocated.
    //	Channel: The channel's buffer is initialized with the specified
    //	buffer capacity. If zero, or the size is omitted, the channel is
    //	unbuffered.
    func make(t Type, size ...IntegerType) Type
    
    // The max built-in function returns the largest value of a fixed number of
    // arguments of [cmp.Ordered] types. There must be at least one argument.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Apr 11 20:22:45 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  6. doc/godebug.md

    enabled by default on listerners. Using multipathtcp="0" reverts to the
    pre-Go 1.24 behavior.
    
    ### Go 1.23
    
    Go 1.23 changed the channels created by package time to be unbuffered
    (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop)
    and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 28 14:46:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  7. cmd/storage-rest-server.go

    	for {
    		_, err := io.ReadFull(respBody, tmp[:])
    		if err != nil {
    			return err
    		}
    		// Check if we have a response ready or a filler byte.
    		switch tmp[0] {
    		case 0:
    			// 0 is unbuffered, copy the rest.
    			_, err := io.CopyBuffer(w, respBody, buf)
    			if err == io.EOF {
    				return nil
    			}
    			return err
    		case 1:
    			errorText, err := io.ReadAll(respBody)
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top