highperfocused/amethyst
1
0
Fork 0
mirror of https://github.com/vitorpamplona/amethyst.git synced 2025-10-04 19:53:28 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1417 from greenart7c3/main

Browse Source 
Change BasicOkHttpWebSocket to be like the docs
This commit is contained in:
Vitor Pamplona
2025-08-18 13:27:52 -04:00
committed by GitHub
parent f5247a5443 e076f97714
commit 9d9b5f03db
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
quartz/src/main/java/com/vitorpamplona/quartz/nip01Core/relay/sockets/okhttp/BasicOkHttpWebSocket.kt
View File

@@ -30,7 +30,7 @@ import okhttp3.Response
class BasicOkHttpWebSocket( class BasicOkHttpWebSocket(
val url: NormalizedRelayUrl, val url: NormalizedRelayUrl,
val httpClient: OkHttpClient, val httpClient: (NormalizedRelayUrl) -> OkHttpClient,
val out: WebSocketListener, val out: WebSocketListener,
) : WebSocket { ) : WebSocket {
private var socket: okhttp3.WebSocket? = null private var socket: okhttp3.WebSocket? = null
@@ -74,7 +74,7 @@ class BasicOkHttpWebSocket(
) = out.onFailure(t, r?.code, r?.message) ) = out.onFailure(t, r?.code, r?.message)
} }
socket = httpClient.newWebSocket(request, listener) socket = httpClient(url).newWebSocket(request, listener)
} }
override fun disconnect() { override fun disconnect() {
@@ -85,7 +85,7 @@ class BasicOkHttpWebSocket(
override fun send(msg: String): Boolean = socket?.send(msg) ?: false override fun send(msg: String): Boolean = socket?.send(msg) ?: false
class Builder( class Builder(
val httpClient: OkHttpClient, val httpClient: (NormalizedRelayUrl) -> OkHttpClient,
) : WebsocketBuilder { ) : WebsocketBuilder {
// Called when connecting. // Called when connecting.
override fun build( override fun build(