- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 154 for Websockets (0.18 sec)
-
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) -
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) -
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) -
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) -
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) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Jun 20 14:10:53 UTC 2024 - 9K bytes - Viewed (0) -
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) -
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) -
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) -
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)