- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 882 for Streams (0.18 sec)
-
guava-tests/test/com/google/common/collect/StreamsTest.java
Stream<String> streamB = Stream.of("b").onClose(closeCountB::incrementAndGet); Stream<String> concatenated = Stream.<Stream<String>>of(Stream.of("a"), streamB, Stream.empty(), Stream.of("c", "d")) .reduce(Stream.empty(), Stream::concat); assertThat(concatenated).containsExactly("a", "b", "c", "d").inOrder(); concatenated.close(); assertThat(closeCountB.get()).isEqualTo(1); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 20K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Connection.kt
* * ## Connection Reuse * * Each connection can carry a varying number of streams, depending on the underlying protocol being * used. HTTP/1.x connections can carry either zero or one streams. HTTP/2 connections can carry any * number of streams, dynamically configured with `SETTINGS_MAX_CONCURRENT_STREAMS`. A connection * currently carrying zero streams is an idle stream. We keep it alive because reusing an existing
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
/** * Returns the number of [open streams][Http2Stream.isOpen] on this connection. */ @Synchronized fun openStreamCount(): Int = streams.size @Synchronized fun getStream(id: Int): Http2Stream? = streams[id] @Synchronized internal fun removeStream(streamId: Int): Http2Stream? { val stream = streams.remove(streamId) // The removed stream may be blocked on a connection-wide window update.
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 32.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
return socket.isHealthy(source) } return true } /** Refuse incoming streams. */ @Throws(IOException::class) override fun onStream(stream: Http2Stream) { stream.close(ErrorCode.REFUSED_STREAM, null) } /** When settings are received, adjust the allocation limit. */ @Synchronized override fun onSettings( connection: Http2Connection,
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Tue Apr 09 03:31:17 GMT 2024 - 15.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/LittleEndianDataOutputStreamTest.java
out.writeUTF("Herby Derby"); out.writeFloat(Float.intBitsToFloat(0xCAFEBABE)); out.writeDouble(Double.longBitsToDouble(0xDEADBEEFCAFEBABEL)); byte[] data = baos.toByteArray(); /* Setup input streams */ DataInput in = new DataInputStream(new ByteArrayInputStream(data)); /* Read in various values NORMALLY */ byte[] b = new byte[2]; in.readFully(b); assertEquals(-100, b[0]);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
} } fun initReaderAndWriter( name: String, streams: Streams, ) { val extensions = this.extensions!! synchronized(this) { this.name = name this.streams = streams this.writer = WebSocketWriter( isClient = streams.client, sink = streams.sink, random = random, perMessageDeflate = extensions.perMessageDeflate,
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/io/package-info.java
* and files. * * <p>At the core of this package are the Source/Sink types: {@link ByteSource ByteSource}, {@link * CharSource CharSource}, {@link ByteSink ByteSink} and {@link CharSink CharSink}. They are * factories for I/O streams that provide many convenience methods that handle both opening and * closing streams for you. *
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Fri Jun 23 19:57:03 GMT 2023 - 1.5K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/collect/StreamsBenchmark.java
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Nov 03 19:39:41 GMT 2016 - 2.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt
val bit = 1 shl ENABLE_PUSH return if (bit and set != 0) values[ENABLE_PUSH] == 1 else defaultValue } fun getMaxConcurrentStreams(): Int { val bit = 1 shl MAX_CONCURRENT_STREAMS return if (bit and set != 0) values[MAX_CONCURRENT_STREAMS] else Int.MAX_VALUE } fun getMaxFrameSize(defaultValue: Int): Int { val bit = 1 shl MAX_FRAME_SIZE return if (bit and set != 0) values[MAX_FRAME_SIZE] else defaultValue }
Plain Text - Registered: Fri Apr 12 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/LittleEndianDataOutputStreamTest.java
out.writeUTF("Herby Derby"); out.writeFloat(Float.intBitsToFloat(0xCAFEBABE)); out.writeDouble(Double.longBitsToDouble(0xDEADBEEFCAFEBABEL)); byte[] data = baos.toByteArray(); /* Setup input streams */ DataInput in = new DataInputStream(new ByteArrayInputStream(data)); /* Read in various values NORMALLY */ byte[] b = new byte[2]; in.readFully(b); assertEquals(-100, b[0]);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4.7K bytes - Viewed (0)