create
inline fun <T> <ERROR CLASS>.createStandardWebsocketFlow( url: String, crossinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, noinline requestBuilder: <ERROR CLASS>.() -> Unit = {}, crossinline conversation: suspend (StandardKtorSerialInputData) -> T): Flow<T>
Content copied to clipboard
inline fun <T> <ERROR CLASS>.createStandardWebsocketFlow( url: String, deserializer: <ERROR CLASS><T>, crossinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, serialFormat: <ERROR CLASS> = standardKtorSerialFormat, noinline requestBuilder: <ERROR CLASS>.() -> Unit = {}): <ERROR CLASS>
Content copied to clipboard
inline fun <T : Any> <ERROR CLASS>.createStandardWebsocketFlow( url: String, noinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, noinline requestBuilder: <ERROR CLASS>.() -> Unit = {}): Flow<T>
Content copied to clipboard
Parameters
check
This lambda will be called when it is required to reconnect to websocket to establish connection. Must return true in case if must be reconnected. By default always reconnecting