Closed
Description
def wrap[T](src: Observable[T]): Observable[T] = {
Observable(subscriber => {
println("subscribed")
subscriber.add(src.subscribe(x => subscriber.onNext(x), e => subscriber.onError(e), () => subscriber.onCompleted()))
})
}
works but this crashes
def wrap[T](src: Observable[T]): Observable[T] = {
Observable(subscriber => {
println("subscribed")
subscriber.add(src.subscribe(subscriber))
})
}
Metadata
Metadata
Assignees
Labels
No labels