map Observable.onError(Throwable) to SendPort.close(Throwable) in