Open stairs opened 6 years ago
Yeah, there's a lot of really hacky Rx code in this branch. Can you do a test and ensure that the socket is indeed staying connected even when there are no subscribers at all? Thanks.
Actually, I face the same problem all around the library. For example, when I try to unsubscribe from the topic it doesn't send unsubscribe message. It appears that doOnCancel
is called when the subscriber is not yet marked as canceled and hence is not deleted from emitters.
I'm not sure how to fix this correctly yet. Do you suggest adding a test to the lib?
I have a downstream branch that contains rewritten Rx logic. More info on 87.
I'm facing the same problem which is described here. The condition for sockets being closed is never met as there is no promise that emitter is already canceled before
doOnCancell()
starts:Here is a link for this code. Proof from RxJava2 repository.