subscribe

fun subscribe(scope: CoroutineScope, onEach: (item: T) -> Unit, onComplete: () -> Unit, onThrow: (error: Throwable) -> Unit): Job