mirror of
https://github.com/vitorpamplona/amethyst.git
synced 2025-11-10 19:36:36 +01:00
Removing onClosing listener because it isn't being used.
This commit is contained in:
@@ -103,12 +103,6 @@ class OkHttpWebSocket(
|
|||||||
incomingMessages.trySendBlocking(text)
|
incomingMessages.trySendBlocking(text)
|
||||||
}
|
}
|
||||||
|
|
||||||
override fun onClosing(
|
|
||||||
webSocket: okhttp3.WebSocket,
|
|
||||||
code: Int,
|
|
||||||
reason: String,
|
|
||||||
) = out.onClosing(code, reason)
|
|
||||||
|
|
||||||
override fun onClosed(
|
override fun onClosed(
|
||||||
webSocket: okhttp3.WebSocket,
|
webSocket: okhttp3.WebSocket,
|
||||||
code: Int,
|
code: Int,
|
||||||
|
|||||||
@@ -170,15 +170,6 @@ open class BasicRelayClient(
|
|||||||
consumeIncomingMessage(text, onConnected)
|
consumeIncomingMessage(text, onConnected)
|
||||||
}
|
}
|
||||||
|
|
||||||
override fun onClosing(
|
|
||||||
code: Int,
|
|
||||||
reason: String,
|
|
||||||
) {
|
|
||||||
Log.w(logTag, "OnClosing $code $reason")
|
|
||||||
|
|
||||||
listener.onRelayStateChange(this@BasicRelayClient, RelayState.DISCONNECTING)
|
|
||||||
}
|
|
||||||
|
|
||||||
override fun onClosed(
|
override fun onClosed(
|
||||||
code: Int,
|
code: Int,
|
||||||
reason: String,
|
reason: String,
|
||||||
|
|||||||
@@ -20,6 +20,10 @@
|
|||||||
*/
|
*/
|
||||||
package com.vitorpamplona.quartz.nip01Core.relay.sockets
|
package com.vitorpamplona.quartz.nip01Core.relay.sockets
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Interface to abstract the socket implementation.
|
||||||
|
* Make sure onMessage appears in order of the receipt.
|
||||||
|
*/
|
||||||
interface WebSocketListener {
|
interface WebSocketListener {
|
||||||
fun onOpen(
|
fun onOpen(
|
||||||
pingMillis: Int,
|
pingMillis: Int,
|
||||||
@@ -28,11 +32,6 @@ interface WebSocketListener {
|
|||||||
|
|
||||||
fun onMessage(text: String)
|
fun onMessage(text: String)
|
||||||
|
|
||||||
fun onClosing(
|
|
||||||
code: Int,
|
|
||||||
reason: String,
|
|
||||||
)
|
|
||||||
|
|
||||||
fun onClosed(
|
fun onClosed(
|
||||||
code: Int,
|
code: Int,
|
||||||
reason: String,
|
reason: String,
|
||||||
|
|||||||
@@ -87,12 +87,6 @@ class BasicOkHttpWebSocket(
|
|||||||
incomingMessages.trySendBlocking(text)
|
incomingMessages.trySendBlocking(text)
|
||||||
}
|
}
|
||||||
|
|
||||||
override fun onClosing(
|
|
||||||
webSocket: OkHttpWebSocket,
|
|
||||||
code: Int,
|
|
||||||
reason: String,
|
|
||||||
) = out.onClosing(code, reason)
|
|
||||||
|
|
||||||
override fun onClosed(
|
override fun onClosed(
|
||||||
webSocket: OkHttpWebSocket,
|
webSocket: OkHttpWebSocket,
|
||||||
code: Int,
|
code: Int,
|
||||||
|
|||||||
Reference in New Issue
Block a user