``` val dataSubject : PublishSubject<Str...

# rx

[chris-hatton]

val dataSubject : PublishSubject<String> = PublishSubject.create()
        val dataSource  : Observable<String> = dataSubject
        val dataRelay   : Subject<String>    = PublishSubject.create()
        dataRelay.subscribeBy( onNext = { println(it) } )
        // TODO Subscribe dataRelay to dataSource
        dataSubject.onNext("Hello world, you see this")
        // TODO Unsubscribe dataRelay from dataSource
        dataSubject.onNext("...but you don't see this.")