eirikb
02/06/2020, 2:24 PMcy
02/06/2020, 2:26 PMcy
02/06/2020, 2:26 PMeirikb
02/06/2020, 2:27 PMcy
02/06/2020, 2:28 PMclient.wss("....") {
incoming.consumeAsFlow() ...
}
?eirikb
02/06/2020, 2:32 PMcy
02/06/2020, 2:37 PMcy
02/06/2020, 2:40 PMfun HttpClient.webSocketFlow(urlString: String): Flow<Frame> = flow {
ws(urlString) {
emitAll(incoming)
}
}
cy
02/06/2020, 2:41 PMclient.webSocketSession(host = "xxx", path = "/endpoint").incoming.consumeAsFlow()
cy
02/06/2020, 2:42 PMeirikb
02/06/2020, 2:54 PMeirikb
02/07/2020, 11:13 AMconsumeAsFlow
because I want multiple listeners. I have managed to create working solution, but it looks messy: https://gist.github.com/eirikb/41910638c2acef9f8f84c43f507f6023 . It also has some issueseirikb
02/07/2020, 11:28 AM