subscribe

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