subscribe

fun <Error class: unknown class><out <Error class: unknown class>>.subscribe(onEach: (item: Any) -> Unit, onComplete: () -> Unit, onThrow: (error: Throwable) -> Unit): <Error class: unknown class>
fun <Error class: unknown class><out <Error class: unknown class>>.subscribe(dispatcher: <Error class: unknown class>, onEach: (item: Any) -> Unit, onComplete: () -> Unit, onThrow: (error: Throwable) -> Unit): <Error class: unknown class>