replayRefCountSubscribeOn.kt

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

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

	val connectable = just(Unit)
			.replay().refCount()

	connectable
			.subscribeOn(newThread())
			.subscribe {
				printCurrentThread("subscribe onNext 1")
			}

	connectable
			.subscribeOn(computation())
			.subscribe {
				printCurrentThread("subscribe onNext 2")
			}

	connectable
			.subscribe {
				printCurrentThread("subscribe onNext 3")
			}

	Thread.sleep(1000L)
}