- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 175 for Buffer (0.13 seconds)
-
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) -
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) -
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) -
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) -
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) -
src/test/java/org/codelibs/fess/timer/LogNotificationTargetTest.java
// Add events to buffer ComponentUtil.getLogNotificationHelper() .offer(new LogNotificationEvent(System.currentTimeMillis(), "ERROR", "org.test", "msg1", null)); ComponentUtil.getLogNotificationHelper() .offer(new LogNotificationEvent(System.currentTimeMillis(), "WARN", "org.test", "msg2", null)); // expired() will drain buffer then fail on OpenSearch (not available) but should not throwCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 4.7K bytes - Click Count (0) -
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) -
android/guava/src/com/google/common/hash/AbstractNonStreamingHashFunction.java
ByteBuffer buffer; ByteBufferHasher(int expectedInputSize) { this.buffer = ByteBuffer.allocate(expectedInputSize).order(ByteOrder.LITTLE_ENDIAN); } /** * Resizes the buffer if necessary. Guaranteed to leave `buffer` in Write Mode ready for new * data. */ private void ensureCapacity(int needed) { if (buffer.remaining() >= needed) { return; }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Dec 04 15:39:10 GMT 2025 - 4.8K bytes - Click Count (0) -
android/guava/src/com/google/common/hash/Murmur3_32HashFunction.java
@CanIgnoreReturnValue @Override public Hasher putBytes(ByteBuffer buffer) { ByteOrder bo = buffer.order(); buffer.order(ByteOrder.LITTLE_ENDIAN); while (buffer.remaining() >= 4) { putInt(buffer.getInt()); } while (buffer.hasRemaining()) { putByte(buffer.get()); } buffer.order(bo); return this; } @CanIgnoreReturnValueCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 19 18:53:45 GMT 2026 - 11.8K bytes - Click Count (0) -
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)