StavFX
10/19/2020, 9:21 PMfun <T> Observable<T>.foo(): ConnectableObservable<T> {
return someOperators...
.replay(1)
.someMoreOperators...
}
connectionStrategy: (ConnectableObservable<T>) -> Observable<T>
and apply it right after the .replay, but that feels dirty