binder-snippets-10.kt

val output: PublishSubject<String> = PublishSubject.create()
val input: Consumer<String> = Consumer { System.out.println(it) }

val lifecycle = ManualLifecycle()
val binder = Binder(lifecycle)

binder.bind(output to input)

output.onNext("1")
lifecycle.begin()
output.onNext("2")
output.onNext("3")
lifecycle.end()
output.onNext("4")
lifecycle.begin()
output.onNext("5")
output.onNext("6")
lifecycle.end()
output.onNext("7")

// will print:
// 2
// 3
// 5
// 6