Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 135 for Buffer (0.49 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/bytes/buffer.go

    // The slice aliases the buffer content at least until the next buffer modification,
    // so immediate changes to the slice will affect the result of future reads.
    func (b *Buffer) Bytes() []byte { return b.buf[b.off:] }
    
    // AvailableBuffer returns an empty buffer with b.Available() capacity.
    // This buffer is intended to be appended to and
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Nov 14 19:01:17 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/hash/HashingInputStreamTest.java

      private static final byte[] testBytes = new byte[] {'y', 'a', 'm', 's'};
      private ByteArrayInputStream buffer;
    
      @SuppressWarnings("DoNotMock")
      @Override
      protected void setUp() throws Exception {
        super.setUp();
        hasher = mock(Hasher.class);
        hashFunction = mock(HashFunction.class);
        buffer = new ByteArrayInputStream(testBytes);
    
        when(hashFunction.newHasher()).thenReturn(hasher);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 5.1K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/hash/HashingInputStreamTest.java

      private static final byte[] testBytes = new byte[] {'y', 'a', 'm', 's'};
      private ByteArrayInputStream buffer;
    
      @SuppressWarnings("DoNotMock")
      @Override
      protected void setUp() throws Exception {
        super.setUp();
        hasher = mock(Hasher.class);
        hashFunction = mock(HashFunction.class);
        buffer = new ByteArrayInputStream(testBytes);
    
        when(hashFunction.newHasher()).thenReturn(hasher);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 5.1K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/curl/io/ContentCacheTest.java

                byte[] buffer1 = new byte[1024];
                int bytesRead1 = stream1.read(buffer1);
                assertEquals(testContent, new String(buffer1, 0, bytesRead1, "UTF-8"));
            }
    
            // Second read - should work independently
            try (InputStream stream2 = cache.getInputStream()) {
                byte[] buffer2 = new byte[1024];
                int bytesRead2 = stream2.read(buffer2);
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 09:11:12 GMT 2026
    - 15.9K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/hash/HashingOutputStreamTest.java

        out.write(b);
    
        verify(hashFunction).newHasher();
        verify(hasher).putByte((byte) b);
        verifyNoMoreInteractions(hashFunction, hasher);
      }
    
      public void testWrite_putByteArray() throws Exception {
        byte[] buf = new byte[] {'y', 'a', 'm', 's'};
        HashingOutputStream out = new HashingOutputStream(hashFunction, buffer);
        out.write(buf);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 3.2K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/Queues.java

       */
      @CanIgnoreReturnValue
      @J2ktIncompatible
      @GwtIncompatible // BlockingQueue
      public static <E> int drain(
          BlockingQueue<E> q, Collection<? super E> buffer, int numElements, Duration timeout)
          throws InterruptedException {
        return drain(q, buffer, numElements, toNanosSaturated(timeout), NANOSECONDS);
      }
    
      /**
       * Drains the queue as {@link BlockingQueue#drainTo(Collection, int)}, but if the requested {@code
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 18K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpHeaders.kt

      }
      return commaFound
    }
    
    private fun Buffer.startsWith(prefix: Byte): Boolean = !exhausted() && this[0] == prefix
    
    /**
     * Reads a double-quoted string, unescaping quoted pairs like `\"` to the 2nd character in each
     * sequence. Returns the unescaped string, or null if the buffer isn't prefixed with a
     * double-quoted string.
     */
    @Throws(EOFException::class)
    private fun Buffer.readQuotedString(): String? {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  8. src/bufio/bufio.go

    	b.n = 0
    	return nil
    }
    
    // Available returns how many bytes are unused in the buffer.
    func (b *Writer) Available() int { return len(b.buf) - b.n }
    
    // AvailableBuffer returns an empty buffer with b.Available() capacity.
    // This buffer is intended to be appended to and
    // passed to an immediately succeeding [Writer.Write] call.
    // The buffer is only valid until the next write operation on b.
    func (b *Writer) AvailableBuffer() []byte {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Feb 06 17:28:40 GMT 2026
    - 22K bytes
    - Click Count (0)
  9. src/bytes/buffer_test.go

    	// Confirm that when Reader panics, the empty buffer remains empty
    	var buf2 Buffer
    	defer func() {
    		recover()
    		check(t, "TestReadFromPanicReader (2)", &buf2, "")
    	}()
    	buf2.ReadFrom(panicReader{panic: true})
    }
    
    func TestReadFromNegativeReader(t *testing.T) {
    	var b Buffer
    	defer func() {
    		switch err := recover().(type) {
    		case nil:
    			t.Fatal("bytes.Buffer.ReadFrom didn't panic")
    		case error:
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Nov 14 19:01:17 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/helper/LogNotificationHelper.java

                logNotificationTarget.flush();
            }
        }
    
        /**
         * Offers an event to the buffer. If the buffer exceeds the maximum size, the oldest event is dropped.
         *
         * @param event the log notification event to add
         */
        public void offer(final LogNotificationEvent event) {
            int maxBufferSize;
            try {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 5.3K bytes
    - Click Count (0)
Back to Top