- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for runcom (0.41 sec)
-
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
// zero effect on the behavior of the WebSocket API which is why tests are only written once // from the perspective of a single peer. private val random = Random(0) private val client2Server = Pipe(8192L) private val server2client = Pipe(8192L) private val taskFaker = TaskFaker() private val client = TestStreams(true, taskFaker, server2client, client2Server)
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/WebSocketHttpTest.kt
private val handshakeCertificates = platform.localhostHandshakeCertificates() private val clientListener = WebSocketRecorder("client") private val serverListener = WebSocketRecorder("server") private val random = Random(0) private var client = clientTestRule.newClientBuilder() .writeTimeout(Duration.ofMillis(500)) .readTimeout(Duration.ofMillis(500)) .addInterceptor(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
class RealWebSocket( taskRunner: TaskRunner, /** The application's original request unadulterated by web socket headers. */ private val originalRequest: Request, internal val listener: WebSocketListener, private val random: Random, private val pingIntervalMillis: Long, /** * For clients this is initially null, and will be assigned to the agreed-upon extensions. For * servers it should be the agreed-upon extensions immediately. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
listener: WebSocketListener, ): WebSocket { val webSocket = RealWebSocket( taskRunner = taskRunner, originalRequest = request, listener = listener, random = Random(), pingIntervalMillis = pingIntervalMillis.toLong(), // extensions is always null for clients: extensions = null, minimumDeflateSize = minWebSocketMessageToCompress,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
} } val webSocket = RealWebSocket( taskRunner = taskRunner, originalRequest = fancyRequest, listener = webSocketResponse.webSocketListener!!, random = SecureRandom(), pingIntervalMillis = 0, extensions = WebSocketExtensions.parse(webSocketResponse.headers), // Compress all messages if compression is enabled. minimumDeflateSize = 0L,
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)