- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 78 for channel (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
} val fileOperator = FileOperator(file!!.channel) fileOperator.write(0, header, FILE_HEADER_SIZE) } @Throws(IOException::class) private fun writeMetadata(upstreamSize: Long) { val metadataBuffer = Buffer() metadataBuffer.write(metadata) val fileOperator = FileOperator(file!!.channel)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java
public UnixDomainSocketFactory(File path) { this.path = path; } @Override public Socket createSocket() throws IOException { UnixSocketChannel channel = UnixSocketChannel.open(); return new TunnelingUnixSocket(path, channel); } @Override public Socket createSocket(String host, int port) throws IOException { Socket result = createSocket(); try {
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Dec 03 21:33:52 GMT 2023 - 2.1K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java
return endpoint; } @Override public Socket accept() throws IOException { try { UnixSocketChannel channel = serverSocketChannel.accept(); return new TunnelingUnixSocket(path, channel, endpoint); } catch (ClosedChannelException e) { SocketException exception = new SocketException(); exception.initCause(e); throw exception; }
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Feb 12 16:33:52 GMT 2019 - 3.1K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
import java.util.Deque import okio.Buffer import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.Test class ServerSentEventIteratorTest { /** Either [Event] or [Long] items for events and retry changes, respectively. */ private val callbacks: Deque<Any> = ArrayDeque() @AfterEach fun after() { assertThat(callbacks).isEmpty() } @Test fun multiline() { consumeEvents( """
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.4K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
impacts VM-wide behavior. * New: Reduce contention for applications that make a very high number of concurrent requests. Previously OkHttp used its connection pool as a lock when making changes to connections and calls. With this change each connection is locked independently. * Upgrade: [Okio 2.7.0][okio_2_7_0]. ```kotlin implementation("com.squareup.okio:okio:2.7.0") ```
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
assertThat(readAscii(in1, 5)).isEqualTo("ABCDE") in1.close() call1.cancel() val call2 = client.newCall(newRequest("/")) val response2 = call2.execute() val in2 = response2.body.byteStream() assertThat(readAscii(in2, 5)).isEqualTo("LMNOP") in2.close() call2.cancel() assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) // Connection is pooled!
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java
private final File path; private InetSocketAddress inetSocketAddress; TunnelingUnixSocket(File path, UnixSocketChannel channel) { super(channel); this.path = path; } TunnelingUnixSocket(File path, UnixSocketChannel channel, InetSocketAddress address) { this(path, channel); this.inetSocketAddress = address; } @Override public void connect(SocketAddress endpoint) throws IOException {
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Feb 12 16:33:52 GMT 2019 - 1.9K bytes - Viewed (1) -
okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt
} @Throws(IOException::class) override fun sendUrgentData(value: Int) { delegate!!.sendUrgentData(value) } override fun getChannel(): SocketChannel { return delegate!!.channel } override fun getHandshakeSession(): SSLSession { return delegate!!.handshakeSession } override fun getApplicationProtocol(): String { return delegate!!.applicationProtocol }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.9K bytes - Viewed (0) -
kotlin-js-store/yarn.lock
integrity sha512-7++dFhtcx3353uBaq8DDR4NuxBetBzC7ZQOhmTQInHEd6bSrXdiEyzCvG07Z44UYdLShWUyXt5M/yhz8ekcb1A== side-channel@^1.0.4: version "1.0.4" resolved "https://registry.yarnpkg.com/side-channel/-/side-channel-1.0.4.tgz#efce5c8fdc104ee751b25c58d4290011fa5ea2cf" integrity sha512-q5XPytqFEIKHkGdiMIrY10mvLRvnQh42/+GoBlFW3b2LXLE2xxJpZFdm94we0BaoV3RwJyGqg5wS7epxTv0Zvw== dependencies:
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jul 22 12:28:51 GMT 2023 - 87.4K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/RtmStartResponse.java
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Oct 23 15:24:22 GMT 2016 - 943 bytes - Viewed (0)