Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for runcom (0.41 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top