Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for shutdownInput (0.04 sec)

  1. mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt

      val handshakeServerNames: List<String>
        get() =
          (javaNetSocket as? SSLSocket)
            ?.let { Platform.Companion.get().getHandshakeServerNames(it) }
            ?: listOf()
    
      fun shutdownInput() {
        javaNetSocket.shutdownInput()
      }
    
      fun shutdownOutput() {
        javaNetSocket.shutdownOutput()
      }
    
      /** Sleeps [nanos], throwing if the socket is closed before that period has elapsed. */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  2. mockwebserver/src/main/kotlin/mockwebserver3/SocketEffect.kt

       *
       * Using this as [MockResponse.onResponseEnd] is the default for HTTP/1.0.
       */
      public class CloseSocket(
        public val closeSocket: Boolean = true,
        public val shutdownInput: Boolean = false,
        public val shutdownOutput: Boolean = false,
      ) : SocketEffect
    
      /**
       * On HTTP/2, send a [GOAWAY frame](https://tools.ietf.org/html/rfc7540#section-6.8) immediately
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt

    /** An [SSLSocket] that delegates all calls.  */
    abstract class DelegatingSSLSocket(
      protected val delegate: SSLSocket?,
    ) : SSLSocket() {
      @Throws(IOException::class)
      override fun shutdownInput() {
        delegate!!.shutdownInput()
      }
    
      @Throws(IOException::class)
      override fun shutdownOutput() {
        delegate!!.shutdownOutput()
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  4. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt

        SocketPolicy.FAIL_HANDSHAKE -> result.failHandshake()
        SocketPolicy.SHUTDOWN_INPUT_AT_END ->
          result.onResponseEnd(
            CloseSocket(
              closeSocket = false,
              shutdownInput = true,
            ),
          )
        SocketPolicy.SHUTDOWN_OUTPUT_AT_END ->
          result.onResponseEnd(
            CloseSocket(
              closeSocket = false,
              shutdownOutput = true,
            ),
          )
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 03 13:16:34 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  5. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

              stream.connection.shutdown(ErrorCode.NO_ERROR)
            } else {
              socket.close()
            }
          }
    
          is CloseSocket -> {
            if (effect.shutdownInput) socket.shutdownInput()
            if (effect.shutdownOutput) socket.shutdownOutput()
            if (effect.closeSocket) socket.close()
          }
    
          Stall -> {
            // Sleep until the socket is closed.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 20:36:00 UTC 2025
    - 40.3K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

          MockResponse
            .Builder()
            .body("This connection won't pool properly")
            .onResponseEnd(
              CloseSocket(
                closeSocket = false,
                shutdownInput = true,
              ),
            ).build(),
        )
      }
    
      @Test
      fun serverShutdownOutput() {
        testServerClosesOutput(
          MockResponse
            .Builder()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
Back to top