advancedMerge.kt

fun printCurrentThread(tag: String) = println("$tag: ${Thread.currentThread().name.substringBefore("-")}")

fun main(args: Array<String>) {
	printCurrentThread("main thread name")

	val subject = BehaviorSubject.create(Unit)

	Observable
			.merge(
					just(Unit),
					subject
			)
			.subscribeOn(computation())
			.subscribe {
				printCurrentThread("subscribe onNext")
			}
	Thread.sleep(100L)

	subject.onNext(Unit)

	Thread.sleep(100L)
}