- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,854 for sink (0.28 sec)
-
guava-tests/test/com/google/common/hash/AbstractStreamingHasherTest.java
Sink sink = new Sink(4); sink.putShort((short) 0x0201); HashCode unused = sink.hash(); sink.assertInvariants(2); sink.assertBytes(new byte[] {1, 2, 0, 0}); // padded with zeros } public void testInt() { Sink sink = new Sink(4); sink.putInt(0x04030201); HashCode unused = sink.hash(); sink.assertInvariants(4); sink.assertBytes(new byte[] {1, 2, 3, 4}); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 8.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
} private suspend fun updateLocalFile() = withContext(Dispatchers.IO) { client.newCall(request).executeAsync().use { response -> fileSystem.sink(publicSuffixListDotDat).buffer().use { sink -> sink.writeAll(response.body.source()) } } } private suspend fun readImportResults(): ImportResults = withContext(Dispatchers.IO) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/ByteSinkTester.java
} return suite; } private ByteSink sink; ByteSinkTester( ByteSinkFactory factory, byte[] data, String suiteName, String caseDesc, Method method) { super(factory, data, suiteName, caseDesc, method); } @Override protected void setUp() throws Exception { sink = factory.createSink(); } public void testOpenStream() throws IOException {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 4K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/ByteSinkTest.java
assertTrue(sink.wasStreamClosed()); assertArrayEquals(new byte[] {1, 2, 3, 4}, sink.getBytes()); } public void testWrite_bytes() throws IOException { assertArrayEquals(new byte[0], sink.getBytes()); sink.write(bytes); assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed()); assertArrayEquals(bytes, sink.getBytes()); } public void testWriteFrom_inputStream() throws IOException {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0) -
okhttp-brotli/src/main/kotlin/okhttp3/brotli/internal/DecompressionBombChecker.kt
private var outputByteCount = 0L fun wrapInput(source: Source): Source { return object : ForwardingSource(source) { override fun read( sink: Buffer, byteCount: Long, ): Long { val result = super.read(sink, byteCount) if (result == -1L) return result inputByteCount += result return result } } }
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 29 22:50:20 GMT 2024 - 1.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
Http1ExchangeCodec(client, this, source, sink) } } @Throws(SocketException::class) internal fun newWebSocketStreams(exchange: Exchange): RealWebSocket.Streams { val socket = this.socket!! val source = this.source!! val sink = this.sink!! socket.soTimeout = 0 noNewExchanges() return object : RealWebSocket.Streams(true, source, sink) { override fun close() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/ByteSourceTest.java
TestByteSink sink = new TestByteSink(); assertFalse(sink.wasStreamOpened() || sink.wasStreamClosed()); assertEquals(bytes.length, source.copyTo(sink)); assertTrue(source.wasStreamOpened() && source.wasStreamClosed()); assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed()); assertArrayEquals(bytes, sink.getBytes()); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 16.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/ByteSinkTest.java
assertTrue(sink.wasStreamClosed()); assertArrayEquals(new byte[] {1, 2, 3, 4}, sink.getBytes()); } public void testWrite_bytes() throws IOException { assertArrayEquals(new byte[0], sink.getBytes()); sink.write(bytes); assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed()); assertArrayEquals(bytes, sink.getBytes()); } public void testWriteFrom_inputStream() throws IOException {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CharSourceTest.java
TestCharSink sink = new TestCharSink(); assertFalse(sink.wasStreamOpened() || sink.wasStreamClosed()); assertEquals(STRING.length(), source.copyTo(sink)); assertTrue(source.wasStreamOpened() && source.wasStreamClosed()); assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed()); assertEquals(STRING, sink.getString()); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 13K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0)