zak.taccardi
04/20/2017, 4:48 PM@Test
fun replayRefCountSubject() {
val relay = BehaviorRelay.create<Int>()
val observable = relay
.replay(1)
.refCount()
relay.accept(1); relay.accept(2); relay.accept(3)
val sub1 = observable.subscribe { println("sub1: $it") }
//want this to print `3`
val sub2 = observable.subscribe { println("sub2: $it") }
//want this to print nothing, because `sub1` already consumed 3
//actual output:
//sub1: 3
//sub2: 3
//actual output if PublishRelay was used instead of Behavior
// (nothing)
}