includeWebsocketHandling

fun <T> <ERROR CLASS>.includeWebsocketHandling(    suburl: String,     flow: Flow<T>,     serializer: <ERROR CLASS><T>,     serialFormat: <ERROR CLASS> = standardKtorSerialFormat,     protocol: <ERROR CLASS>? = null,     filter: suspend <ERROR CLASS>.(T) -> Boolean? = null): <ERROR CLASS>
inline fun <T : Any> <ERROR CLASS>.includeWebsocketHandling(    suburl: String,     flow: Flow<T>,     protocol: <ERROR CLASS>? = null,     noinline dataMapper: suspend <ERROR CLASS>.(T) -> T? = { it })