successOnlyCacheTest.lt

    @Test(timeout = 10000)
    fun secondSubscription_returnsImmediate() {
        val subject = PublishSubject.create<Int>()
        val cachedSubject = subject.successOnlyCache()

        cachedSubject.test() //first subscription
        cachedSubject.test() //second subscription

        //this method will never finishes if subscription is blocked.
    }