korge-core/korlibs.io.net.ws/RawSocketWebSocketClient

RawSocketWebSocketClient

class RawSocketWebSocketClient(val coroutineContext: CoroutineContext, val client: AsyncClient, val urlUrl: URL, val protocols: List<String>? = null, debug: Boolean = false, val origin: String? = null, val key: String = DEFAULT_WSKEY, val headers: Http.Headers = Http.Headers(), val masked: Boolean = true, val random: Random = Random) : WebSocketClient

Constructors

RawSocketWebSocketClient

constructor(coroutineContext: CoroutineContext, client: AsyncClient, urlUrl: URL, protocols: List<String>? = null, debug: Boolean = false, origin: String? = null, key: String = DEFAULT_WSKEY, headers: Http.Headers = Http.Headers(), masked: Boolean = true, random: Random = Random)

Types

object Companion

Properties

val client: AsyncClient

var closed: Boolean

coroutineContext

val coroutineContext: CoroutineContext

val headers: Http.Headers

val host: String

val key: String

val masked: Boolean = true

val onAnyMessage: Signal<Any>

onBinaryMessage

val onBinaryMessage: Signal<ByteArray>

val onClose: Signal<WebSocketClient.CloseInfo>

val onError: Signal<Throwable>

val onOpen: Signal<Unit>

onStringMessage

val onStringMessage: Signal<String>

val origin: String? = null

val protocols: List<String>?

val random: Random

val url: String

val urlUrl: URL

Functions

open override fun close(code: Int, reason: String)

fun close(info: WsCloseInfo)

internalConnect

suspend fun internalConnect()

internalReadPackets

suspend fun internalReadPackets()

fun messageChannel(limit: Int = Channel.UNLIMITED): Channel<Any>

messageChannelBinary

fun messageChannelBinary(limit: Int = Channel.UNLIMITED): Channel<Any>

messageChannelString

fun messageChannelString(limit: Int = Channel.UNLIMITED): Channel<Any>

suspend fun readWsFrame(): WsFrame

readWsFrameOrNull

suspend fun readWsFrameOrNull(): WsFrame?

open suspend override fun send(message: ByteArray)

open suspend override fun send(message: String)

suspend fun sendWsFrame(frame: WsFrame, random: Random = this.random)