which you can do with RxJava by doing `replay(1).a...

# rx

[jw]

which you can do with RxJava by doing replay(1).autoConnect(), but then it will never disconnect from upstream if the count goes to 0