Home / Input Output / scalanet
41 commits this week Jun 10, 2019 - Jun 17, 2019
A-667: Identify and fix server channel reception bug
- UDPPeergroup returns a monix PublishSubject to expose the stream of channels that a peer receives to communicate with clients.
This has the characteristic that, no channel received before the subscription to the
server()stream will actually be notified to the user.
- This commit changes the use of PublishSubject for ReplaySubject. The semantics of ReplaySubject is that the channels received before the
subscription will arrive to the user. This is the same behaviour we have in the
inmethod of UPD channels’s implementation.
- This solves a requirement need, however, this could also create problems in other use cases. A proper solution should be discussed.