Have you tried just using a `Cache`? ```Cache<K...

# rx

[expensivebelly]

Have you tried just using a Cache?

Cache<K, Observable<T>>

Then you can replayingShare() each observable within the cache (https://github.com/JakeWharton/RxReplayingShare)

[StavFX]

I guess that's possible if the keys are known ahead of time.
I think trying to get away with re-using existing operators doesn't fit this case, and I should just wrap this all up in a proper ObservableTransformer. Then I could keep Cache<K, T> and just emit the values to new subscribers.