subscribe

abstract fun subscribe(fn: (value: T) -> Unit): () -> Unit(source)