@RyanHurst: Would you mind reviewing this PR by testing if this solves your problem before I merge?
It may not be super easy to read in the templates, but I essentially to the following:
Save the flowables as members, so that calls like telemetry.armed() always get the same object (before it was creating a new one everytime, registering a new callback to the C++ SDK).
Use RxJava2's replay and autoConnect operators to "share" the subscription between all the subscribers of that shared object, with:
@RyanHurst: Would you mind reviewing this PR by testing if this solves your problem before I merge?
It may not be super easy to read in the templates, but I essentially to the following:
Save the flowables as members, so that calls like
telemetry.armed()always get the same object (before it was creating a new one everytime, registering a new callback to the C++ SDK).Use RxJava2's
replayandautoConnectoperators to "share" the subscription between all the subscribers of that shared object, with:Resolves #3.