diff --git a/src/main/scala/rx/lang/scala/Observable.scala b/src/main/scala/rx/lang/scala/Observable.scala index ac53ec80..7a94c2ad 100755 --- a/src/main/scala/rx/lang/scala/Observable.scala +++ b/src/main/scala/rx/lang/scala/Observable.scala @@ -4435,7 +4435,9 @@ object Observable { * @param scheduler the Scheduler on which to call `onError` * @tparam T the type of the items (ostensibly) emitted by the Observable * @return an Observable that invokes the `Observer`'s `onError` method, on the specified Scheduler + * @deprecated use `#subscribeOn` to schedule */ + @deprecated("Use with `error(Throwable).subscribeOn` instead", "0.20") def error[T](exception: Throwable, scheduler: Scheduler): Observable[T] = { toScalaObservable[T](rx.Observable.error(exception, scheduler)) } @@ -4473,7 +4475,9 @@ object Observable { * specified scheduler * @see RxJava Wiki: empty() * @see MSDN: Observable.Empty Method (IScheduler) + * @deprecated use `#subscribeOn` to schedule */ + @deprecated("Use `empty.subscribeOn` instead", "0.20") def empty(scheduler: Scheduler): Observable[Nothing] = { toScalaObservable(rx.Observable.empty[Nothing](scalaSchedulerToJavaScheduler(scheduler))) }