- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for asBufferedSocket (0.83 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
// More details: // https://github.com/square/okhttp/issues/3245 // https://android-review.googlesource.com/#/c/271775/ try { this.socket = rawSocket.asBufferedSocket() } catch (npe: NullPointerException) { if (npe.message == NPE_THROW_WITH_NULL) { throw IOException(npe) } } } /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 18.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.concurrent.assertLockHeld import okhttp3.internal.connection.BufferedSocket import okhttp3.internal.connection.RealCall import okhttp3.internal.connection.asBufferedSocket import okhttp3.internal.okHttpName import okhttp3.internal.ws.WebSocketProtocol.CLOSE_CLIENT_GOING_AWAY import okhttp3.internal.ws.WebSocketProtocol.CLOSE_MESSAGE_MAX
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 21.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt
peer.acceptFrame() // PING peer.play() // Play it back. val connection = Http2Connection .Builder(true, TaskRunner.INSTANCE) .socket(peer.openSocket().asBufferedSocket(), "peer") .pushObserver(Http2ConnectionTest.IGNORE) .listener(realConnection) .build() connection.start(sendConnectionPreface = false) // verify the peer received the ACK
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 12.9K bytes - Viewed (0)