cypressious · May 25, 2016 21:09
diff --git a/delayUntilTest1.kt b/delayUntilTest1.kt
 val mutex = Semaphore(0)
 val source = Observable.interval(200, TimeUnit.MILLISECONDS).take(10)
 val delayed =  source.delayUntil(3L)

 println("${System.currentTimeMillis()}: start")
 delayed.subscribe(
        { println("${System.currentTimeMillis()}: $it") },
        { println("Failed with $it") },
        { mutex.release() }
 )

 mutex.acquire()
	val mutex = Semaphore(0)
	val source = Observable.interval(200, TimeUnit.MILLISECONDS).take(10)
	val delayed = source.delayUntil(3L)

	println("${System.currentTimeMillis()}: start")
	delayed.subscribe(
	{ println("${System.currentTimeMillis()}: $it") },
	{ println("Failed with $it") },
	{ mutex.release() }
	)

	mutex.acquire()