We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b7515ed commit b7cfcbaCopy full SHA for b7cfcba
language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/Observable.scala
@@ -2285,6 +2285,7 @@ object Observable {
2285
* @return
2286
* an Observable that, when an [[rx.lang.scala.Observer]] subscribes to it, will execute the given function.
2287
*/
2288
+ @deprecated("Use `apply[T](Subscriber[T] => Unit)` instead", "0.17.0")
2289
def create[T](func: Observer[T] => Subscription): Observable[T] = {
2290
toScalaObservable[T](rx.Observable.create(new OnSubscribeFunc[T] {
2291
def onSubscribe(t1: rx.Observer[_ >: T]): rx.Subscription = {
0 commit comments