HairPullingTestLogged.kt

@RunWith(MockitoJUnitRunner::class)
class HairPullingTest {

    private  var testScheduler = TestScheduler()
    @Test
    fun testVodoo() {
        val subject:PublishSubject<Int> = PublishSubject.create()
        val testObserver = subject
            .subscribeOn(testScheduler)
            .observeOn(testScheduler)
            .doOnSubscribe {
                print("I've subscribed")
            }.test()
        print("Emitting Item")
        subject.onNext(1)
        testScheduler.triggerActions()
        testObserver.assertValueCount(1)
    }
}