you can do it multiple ways, with `Subject`, with ...

# arrow

[pakoito]

you can do it multiple ways, with Subject, with Observable.create, and with ObservableK.async. The first one is more imperative (read easier) and doesn't have coordinated cancellation or cleanup. If you want to close the websocket when there's a failure, use Observable.create. ObservableK.async will get support for that too soon, thanks to @simon.vergauwen and @Jorge Castillo

[kitttn]

Thanks, @pakoito!