@bamdmux I can, I was doing wrong thing. I wanted to create two PublishSubscribers and push data to them from websocket on different threads. I tried just to
subscribeOn()
but after reading posts and documentation I found that I need to flatMap first