- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for Signal (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
signalledCallback = true responseCallback.onResponse(this@RealCall, response) } catch (e: IOException) { if (signalledCallback) { // Do not signal the callback twice! Platform.get().log("Callback failure for ${toLoggableString()}", Platform.INFO, e) } else { responseCallback.onFailure(this@RealCall, e) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
SynchronousQueue(), threadFactory, ) override fun nanoTime() = System.nanoTime() override fun coordinatorNotify(taskRunner: TaskRunner) { taskRunner.condition.signal() } /** * Wait a duration in nanoseconds. Unlike [java.lang.Object.wait] this interprets 0 as * "don't wait" instead of "wait forever". */ @Throws(InterruptedException::class)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.7K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
webSocket.initReaderAndWriter(name, streams) try { webSocket.loopReader(fancyResponse) // Even if messages are no longer being read we need to wait for the connection close signal. connectionClose.await() } finally { source.closeQuietly() } } @Throws(IOException::class) private fun writeHttpResponse( socket: Socket, sink: BufferedSink,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
mockwebserver/api/mockwebserver3.api
public final fun getPort ()I public final fun getProtocolNegotiationEnabled ()Z public final fun getProtocols ()Ljava/util/List; public final fun getRequestCount ()I public final fun getServerSocketFactory ()Ljavax/net/ServerSocketFactory; public final fun getStarted ()Z public final fun noClientAuth ()V public final fun requestClientAuth ()V public final fun requireClientAuth ()V
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 03 21:59:45 GMT 2023 - 12.7K bytes - Viewed (0) -
gradle/wrapper/gradle-wrapper.jar
validateDistribution; public void WrapperConfiguration(); public final void setDistribution(java.net.URI); public final String getDistributionBase(); public final void setDistributionBase(String); public final String getDistributionPath(); public final void setDistributionPath(String); public final String getDistributionSha25(); public final void setDistributionSha25(String); public final String getZipBase(); public final void setZipBase(String); public final String getZipPath(); public final void setZipPath(String);...
Archive - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Dec 24 09:00:26 GMT 2023 - 42.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
server.sink.write("0a00".decodeHex()).emit() // Invalid non-final ping frame. client.processNextFrame() // Detects error, send close, close connection. taskFaker.runTasks() client.webSocket!!.finishReader() assertThat(client.closed).isTrue() client.listener.assertFailure( ProtocolException::class.java, "Control frames must be final.", ) server.processNextFrame() taskFaker.runTasks()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
assertFailsWith<ProtocolException> { clientReader.processNextFrame() }.also { expected -> assertThat(expected.message) .isEqualTo("Control frames must be final.") } } @Test fun reservedFlag1IsUnsupportedWithNoCompression() { data.write("ca00".decodeHex()) // Empty pong, flag 1 set. assertFailsWith<ProtocolException> { clientReader.processNextFrame()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionSpec.kt
} else { sslSocket.enabledProtocols } // In accordance with https://tools.ietf.org/html/draft-ietf-tls-downgrade-scsv-00 the SCSV // cipher is added to signal that a protocol fallback has taken place. val supportedCipherSuites = sslSocket.supportedCipherSuites val indexOfFallbackScsv = supportedCipherSuites.indexOf( "TLS_FALLBACK_SCSV",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 13.4K bytes - Viewed (0) -
CHANGELOG.md
The alpha releases in the 5.0.0 series have production-quality code and an unstable API. We expect to make changes to the APIs introduced in 5.0.0-alpha.X. These releases are safe for production use and 'alpha' strictly signals that we're still experimenting with some new APIs. If you're eager for the fixes or features below, please upgrade. * New: Named and default parameters constructor for `Request`: ```
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0)