``` val relay = PublishSubject.create<I...

# rx

[robinchew]

val relay = PublishSubject.create<Int>();

        relay.scan(
            "zero",
            {old, new -> "${old} ${new}"}
        ).subscribe {println("emits: ${it}")}

        relay.onNext(2)
        relay.onNext(3)