Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 154 for Websockets (0.18 sec)

  1. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt

        }
    
      fun withWebSocketUpgrade(listener: WebSocketListener) =
        apply {
          status = "HTTP/1.1 101 Switching Protocols"
          setHeader("Connection", "Upgrade")
          setHeader("Upgrade", "websocket")
          body = null
          webSocketListener = listener
        }
    
      override fun toString(): String = status
    
      companion object {
        private const val CHUNKED_BODY_HEADER = "Transfer-encoding: chunked"
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    // IsOnline - returns whether client failed to connect or not.
    func (client *storageRESTClient) IsOnline() bool {
    	return client.restClient.IsOnline() || client.IsOnlineWS()
    }
    
    // IsOnlineWS - returns whether websocket client failed to connect or not.
    func (client *storageRESTClient) IsOnlineWS() bool {
    	return client.gridConn.State() == grid.StateConnected
    }
    
    // LastConn - returns when the disk is seen to be connected the last time
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. internal/http/listener.go

    	Interface   string           // This is a VRF device passed via `--interface` flag
    	Trace       func(msg string) // Trace when starting.
    }
    
    // ForWebsocket returns TCPOptions valid for websocket net.Conn
    func (t TCPOptions) ForWebsocket() TCPOptions {
    	return TCPOptions{
    		UserTimeout: t.UserTimeout,
    		Interface:   t.Interface,
    		SendBufSize: t.SendBufSize,
    		RecvBufSize: t.RecvBufSize,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  4. docs/changelogs/changelog_4x.md

     [fun_interface]: https://kotlinlang.org/docs/reference/fun-interfaces.html
     [iana_websocket]: https://www.iana.org/assignments/websocket/websocket.txt
     [jetty_8_252]: https://webtide.com/jetty-alpn-java-8u252/
     [kotlin_1_3_71]: https://github.com/JetBrains/kotlin/releases/tag/v1.3.71
     [kotlin_1_4_10]: https://github.com/JetBrains/kotlin/releases/tag/v1.4.10
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  5. internal/grid/grid.go

    		}
    		dialer.TLSConfig = tls
    
    		conn, br, _, err := dialer.Dial(ctx, toDial)
    		if br != nil {
    			ws.PutReader(br)
    		}
    		return conn, err
    	}
    }
    
    // ConnectWS returns a function that dials a websocket connection to the given address.
    // Route and auth are added to the connection.
    func ConnectWS(dial ContextDialer, auth AuthFn, tls *tls.Config) func(ctx context.Context, remote string) (net.Conn, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

       *
       * If more than [maxRequestsPerHost] requests are in flight when this is invoked, those requests
       * will remain in flight.
       *
       * WebSocket connections to hosts **do not** count against this limit.
       */
      var maxRequestsPerHost = 5
        get() = this.withLock { field }
        set(maxRequestsPerHost) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Jun 20 14:10:53 UTC 2024
    - 9K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt

    import okhttp3.internal.ws.WebSocketProtocol.toggleMask
    import okio.Buffer
    import okio.BufferedSource
    import okio.ByteString
    
    /**
     * An [RFC 6455][rfc_6455]-compatible WebSocket frame reader.
     *
     * This class is not thread safe.
     *
     * [rfc_6455]: http://tools.ietf.org/html/rfc6455
     */
    class WebSocketReader(
      private val isClient: Boolean,
      val source: BufferedSource,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  8. docs/nl/docs/features.md

    * Zeer indrukwekkende prestaties. Het is <a href="https://github.com/encode/starlette#performance" class="external-link" target="_blank">een van de snelste Python frameworks, vergelijkbaar met **NodeJS** en **Go**</a>.
    * **WebSocket** ondersteuning.
    * Taken in de achtergrond tijdens het proces.
    * Opstart- en afsluit events.
    * Test client gebouwd op HTTPX.
    * **CORS**, GZip, Statische bestanden, Streaming reacties.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Sep 03 13:50:38 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  9. mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

         */
        fun webSocketUpgrade(listener: WebSocketListener) =
          apply {
            status = "HTTP/1.1 101 Switching Protocols"
            setHeader("Connection", "Upgrade")
            setHeader("Upgrade", "websocket")
            webSocketListener = listener
          }
    
        /**
         * Configures this response to be served as a response to an HTTP CONNECT request, either for
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. docs/ru/docs/features.md

    * Поддержка **WebSocket**.
    * Фоновые задачи для процессов.
    * События запуска и выключения.
    * Тестовый клиент построен на библиотеке HTTPX.
    * **CORS**, GZip, статические файлы, потоковые ответы.
    * Поддержка **сессий и cookie**.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
Back to top