Class/Object

monifu.reactive.channels

BehaviorChannel

Related Docs: object BehaviorChannel | package channels

Permalink

final class BehaviorChannel[T] extends ObservableChannel[T, T]

A BehaviorChannel is a Channel that uses an underlying BehaviorSubject.

Source
BehaviorChannel.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. BehaviorChannel
  2. ObservableChannel
  3. LiftOperators2
  4. Channel
  5. Observable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. def ++[U >: T](other: ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  4. def +:[U >: T](elem: U): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  5. def :+[U >: T](elem: U): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  6. def :=(update: T): Unit

    Permalink
  7. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  8. def ambWith[U >: T](other: Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  9. def apply(): T

    Permalink
  10. def asFuture(implicit s: Scheduler): Future[Option[T]]

    Permalink

    Returns the first generated result as a Future and then cancels the subscription.

    Returns the first generated result as a Future and then cancels the subscription.

    Definition Classes
    Observable
  11. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  12. def asyncBoundary[U >: T](overflowStrategy: Evicted, onOverflow: (Long) ⇒ U): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  13. def asyncBoundary(overflowStrategy: OverflowStrategy): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  14. def behavior[U >: T](initialValue: U)(implicit s: Scheduler): ConnectableObservable[U]

    Permalink

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e.

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e. whose source is shared by all observers). The underlying subject used is a BehaviorSubject.

    Definition Classes
    Observable
  15. def buffer(timespan: FiniteDuration, maxSize: Int): ObservableChannel[T, Seq[T]]

    Permalink
    Definition Classes
    LiftOperators2
  16. def buffer(timespan: FiniteDuration): ObservableChannel[T, Seq[T]]

    Permalink
    Definition Classes
    LiftOperators2
  17. def buffer(count: Int, skip: Int): ObservableChannel[T, Seq[T]]

    Permalink
    Definition Classes
    LiftOperators2
  18. def buffer(count: Int): ObservableChannel[T, Seq[T]]

    Permalink
    Definition Classes
    LiftOperators2
  19. def bufferIntrospective(maxSize: Int): Observable[List[T]]

    Permalink

    Buffers signals while busy, after which it emits the buffered events as a single bundle.

    Buffers signals while busy, after which it emits the buffered events as a single bundle.

    This operator starts applying back-pressure when the underlying buffer's size is exceeded.

    Definition Classes
    Observable
  20. def cache(maxCapacity: Int): Observable[T]

    Permalink

    Caches the emissions from the source Observable and replays them in order to any subsequent Subscribers.

    Caches the emissions from the source Observable and replays them in order to any subsequent Subscribers. This method has similar behavior to replay except that this auto-subscribes to the source Observable rather than returning a ConnectableObservable for which you must call connect to activate the subscription.

    When you call cache, it does not yet subscribe to the source Observable and so does not yet begin caching items. This only happens when the first Subscriber calls the resulting Observable's subscribe method.

    maxCapacity

    is the maximum buffer size after which old events start being dropped (according to what happens when using ReplaySubject.createWithSize)

    returns

    an Observable that, when first subscribed to, caches all of its items and notifications for the benefit of subsequent subscribers

    Definition Classes
    Observable
  21. def cache: Observable[T]

    Permalink

    Caches the emissions from the source Observable and replays them in order to any subsequent Subscribers.

    Caches the emissions from the source Observable and replays them in order to any subsequent Subscribers. This method has similar behavior to replay except that this auto-subscribes to the source Observable rather than returning a ConnectableObservable for which you must call connect to activate the subscription.

    When you call cache, it does not yet subscribe to the source Observable and so does not yet begin caching items. This only happens when the first Subscriber calls the resulting Observable's subscribe method.

    Note: You sacrifice the ability to cancel the origin when you use the cache operator so be careful not to use this on Observables that emit an infinite or very large number of items that will use up memory.

    returns

    an Observable that, when first subscribed to, caches all of its items and notifications for the benefit of subsequent subscribers

    Definition Classes
    Observable
  22. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  23. def collect[U](pf: PartialFunction[T, U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  24. def combineLatest[U](other: Observable[U]): ObservableChannel[T, (T, U)]

    Permalink
    Definition Classes
    LiftOperators2
  25. def combineLatestDelayError[U](other: Observable[U]): ObservableChannel[T, (T, U)]

    Permalink
    Definition Classes
    LiftOperators2
  26. def complete: ObservableChannel[T, Nothing]

    Permalink
    Definition Classes
    LiftOperators2
  27. def concat[U](implicit ev: <:<[T, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  28. def concatDelayError[U](implicit ev: <:<[T, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  29. def concatMap[U](f: (T) ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  30. def concatMapDelayError[U](f: (T) ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  31. def count: ObservableChannel[T, Long]

    Permalink
    Definition Classes
    LiftOperators2
  32. def debounce[U](selector: (T) ⇒ Observable[Any], f: (T) ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  33. def debounce(selector: (T) ⇒ Observable[Any]): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  34. def debounce[U](timeout: FiniteDuration, f: (T) ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  35. def debounce(timeout: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  36. def debounceRepeated(period: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  37. def defaultIfEmpty[U >: T](default: U): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  38. def delay[U](selector: (T) ⇒ Observable[U]): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  39. def delay(duration: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  40. def delaySubscription(timespan: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  41. def delaySubscription[U](trigger: Observable[U]): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  42. def distinct[U](fn: (T) ⇒ U): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  43. def distinct: ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  44. def distinctUntilChanged[U](fn: (T) ⇒ U): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  45. def distinctUntilChanged: ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  46. def doOnCanceled(cb: ⇒ Unit): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  47. def doOnComplete(cb: ⇒ Unit): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  48. def doOnError(cb: (Throwable) ⇒ Unit): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  49. def doOnStart(cb: (T) ⇒ Unit): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  50. def doWork(cb: (T) ⇒ Unit): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  51. def drop(n: Int): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  52. def dropByTimespan(timespan: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  53. def dropWhile(p: (T) ⇒ Boolean): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  54. def dropWhileWithIndex(p: (T, Int) ⇒ Boolean): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  55. def dump(prefix: String, out: PrintStream = System.out): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  56. def echoOnce(timeout: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  57. def echoRepeated(timeout: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  58. def endWith[U >: T](elems: U*): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  59. def endWithError(error: Throwable): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  60. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  61. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  62. def error: ObservableChannel[T, Throwable]

    Permalink
    Definition Classes
    LiftOperators2
  63. def exists(p: (T) ⇒ Boolean): ObservableChannel[T, Boolean]

    Permalink
    Definition Classes
    LiftOperators2
  64. def filter(p: (T) ⇒ Boolean): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  65. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  66. def find(p: (T) ⇒ Boolean): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  67. def firstOrElse[U >: T](default: ⇒ U): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  68. def flatMap[U](f: (T) ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  69. def flatMapDelayError[U](f: (T) ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  70. def flatMapLatest[U](f: (T) ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  71. def flatScan[R](initial: R)(op: (R, T) ⇒ Observable[R]): ObservableChannel[T, R]

    Permalink
    Definition Classes
    LiftOperators2
  72. def flatScanDelayError[R](initial: R)(op: (R, T) ⇒ Observable[R]): ObservableChannel[T, R]

    Permalink
    Definition Classes
    LiftOperators2
  73. def flatten[U](implicit ev: <:<[T, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  74. def flattenDelayError[U](implicit ev: <:<[T, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  75. def flattenLatest[U](implicit ev: <:<[T, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  76. def foldLeft[R](initial: R)(op: (R, T) ⇒ R): ObservableChannel[T, R]

    Permalink
    Definition Classes
    LiftOperators2
  77. def forAll(p: (T) ⇒ Boolean): ObservableChannel[T, Boolean]

    Permalink
    Definition Classes
    LiftOperators2
  78. def foreach(cb: (T) ⇒ Unit)(implicit s: Scheduler): Unit

    Permalink

    Subscribes to the source Observable and foreach element emitted by the source it executes the given callback.

    Subscribes to the source Observable and foreach element emitted by the source it executes the given callback.

    Definition Classes
    Observable
  79. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  80. def groupBy[K](keyBufferSize: Int, keySelector: (T) ⇒ K): ObservableChannel[T, GroupedObservable[K, T]]

    Permalink
    Definition Classes
    LiftOperators2
  81. def groupBy[K](keySelector: (T) ⇒ K): ObservableChannel[T, GroupedObservable[K, T]]

    Permalink
    Definition Classes
    LiftOperators2
  82. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  83. def head: ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  84. def headOrElse[B >: T](default: ⇒ B): ObservableChannel[T, B]

    Permalink
    Definition Classes
    LiftOperators2
  85. def ignoreElements: ObservableChannel[T, Nothing]

    Permalink
    Definition Classes
    LiftOperators2
  86. def isEmpty: ObservableChannel[T, Boolean]

    Permalink
    Definition Classes
    LiftOperators2
  87. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  88. def last: ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  89. def lift[U](f: (Observable[T]) ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  90. def liftToSelf[U](f: (Observable[T]) ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Attributes
    protected
    Definition Classes
    ObservableChannelLiftOperators2
  91. def map[U](f: (T) ⇒ U): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  92. def materialize: ObservableChannel[T, Notification[T]]

    Permalink
    Definition Classes
    LiftOperators2
  93. def max[U >: T](implicit ev: Ordering[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  94. def maxBy[U](f: (T) ⇒ U)(implicit ev: Ordering[U]): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  95. def merge[U](overflowStrategy: Evicted, onOverflow: (Long) ⇒ U)(implicit ev: <:<[T, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  96. def merge[U](overflowStrategy: OverflowStrategy)(implicit ev: <:<[T, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  97. def merge[U](implicit ev: <:<[T, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  98. def mergeDelayErrors[U](overflowStrategy: Evicted, onOverflow: (Long) ⇒ U)(implicit ev: <:<[T, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  99. def mergeDelayErrors[U](overflowStrategy: OverflowStrategy)(implicit ev: <:<[T, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  100. def mergeDelayErrors[U](implicit ev: <:<[T, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  101. def mergeMap[U](f: (T) ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  102. def mergeMapDelayErrors[U](f: (T) ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  103. def min[U >: T](implicit ev: Ordering[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  104. def minBy[U](f: (T) ⇒ U)(implicit ev: Ordering[U]): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  105. def multicast[U >: T, R](subject: Subject[U, R])(implicit s: Scheduler): ConnectableObservable[R]

    Permalink

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e.

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e. whose source is shared by all observers).

    Definition Classes
    Observable
  106. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  107. def nonEmpty: ObservableChannel[T, Boolean]

    Permalink
    Definition Classes
    LiftOperators2
  108. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  109. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  110. def onErrorFallbackTo[U >: T](that: ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  111. def onErrorRecoverWith[U >: T](pf: PartialFunction[Throwable, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  112. def onErrorRetry(maxRetries: Long): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  113. def onErrorRetryIf(p: (Throwable) ⇒ Boolean): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  114. def onErrorRetryUnlimited: ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  115. def onSubscribe(subscriber: Subscriber[T]): Unit

    Permalink

    Characteristic function for an Observable instance, that creates the subscription and that eventually starts the streaming of events to the given Observer, being meant to be overridden in custom combinators or in classes implementing Observable.

    Characteristic function for an Observable instance, that creates the subscription and that eventually starts the streaming of events to the given Observer, being meant to be overridden in custom combinators or in classes implementing Observable.

    This function is "unsafe" to call because it does not protect the calls to the given Observer implementation in regards to unexpected exceptions that violate the contract, therefore the given instance must respect its contract and not throw any exceptions when the observable calls onNext, onComplete and onError. If it does, then the behavior is undefined.

    Definition Classes
    BehaviorChannelObservable
    See also

    subscribe.

  116. def onSubscribe(observer: Observer[T])(implicit s: Scheduler): Unit

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    This function is "unsafe" to call because it does not protect the calls to the given Observer implementation in regards to unexpected exceptions that violate the contract, therefore the given instance must respect its contract and not throw any exceptions when the observable calls onNext, onComplete and onError. If it does, then the behavior is undefined.

    observer

    is an Observer that respects the Monifu Rx contract

    s

    is the Scheduler used for creating the subscription

    Definition Classes
    Observable
  117. def publish(implicit s: Scheduler): ConnectableObservable[T]

    Permalink

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e.

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e. whose source is shared by all observers). The underlying subject used is a PublishSubject.

    Definition Classes
    Observable
  118. def publishLast(implicit s: Scheduler): ConnectableObservable[T]

    Permalink

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e.

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e. whose source is shared by all observers). The underlying subject used is a AsyncSubject.

    Definition Classes
    Observable
  119. def pushComplete(): Unit

    Permalink

    End the stream.

    End the stream.

    Definition Classes
    BehaviorChannelChannel
  120. def pushError(ex: Throwable): Unit

    Permalink

    Ends the stream with an error.

    Ends the stream with an error.

    Definition Classes
    BehaviorChannelChannel
  121. def pushNext(elems: T*): Unit

    Permalink

    Push the given events down the stream.

    Push the given events down the stream.

    Definition Classes
    BehaviorChannelChannel
  122. def reduce[U >: T](op: (U, U) ⇒ U): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  123. def repeat: ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  124. def replay(bufferSize: Int)(implicit s: Scheduler): ConnectableObservable[T]

    Permalink

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e.

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e. whose source is shared by all observers). The underlying subject used is a ReplaySubject.

    bufferSize

    is the size of the buffer limiting the number of items that can be replayed (on overflow the head starts being dropped)

    Definition Classes
    Observable
  125. def replay(implicit s: Scheduler): ConnectableObservable[T]

    Permalink

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e.

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e. whose source is shared by all observers). The underlying subject used is a ReplaySubject.

    Definition Classes
    Observable
  126. def sample[U](sampler: Observable[U]): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  127. def sample(initialDelay: FiniteDuration, delay: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  128. def sample(delay: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  129. def sampleRepeated[U](sampler: Observable[U]): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  130. def sampleRepeated(initialDelay: FiniteDuration, delay: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  131. def sampleRepeated(delay: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  132. def scan[R](initial: R)(op: (R, T) ⇒ R): ObservableChannel[T, R]

    Permalink
    Definition Classes
    LiftOperators2
  133. implicit val scheduler: Scheduler

    Permalink
  134. def share(implicit s: Scheduler): Observable[T]

    Permalink

    Returns a new Observable that multi-casts (shares) the original Observable.

    Returns a new Observable that multi-casts (shares) the original Observable.

    Definition Classes
    Observable
  135. def startWith[U >: T](elems: U*): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  136. def subscribe(nextFn: (T) ⇒ Future[Ack])(implicit s: Scheduler): BooleanCancelable

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    returns

    a subscription that can be used to cancel the streaming.

    Definition Classes
    Observable
  137. def subscribe()(implicit s: Scheduler): Cancelable

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    returns

    a subscription that can be used to cancel the streaming.

    Definition Classes
    Observable
  138. def subscribe(nextFn: (T) ⇒ Future[Ack], errorFn: (Throwable) ⇒ Unit)(implicit s: Scheduler): BooleanCancelable

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    returns

    a subscription that can be used to cancel the streaming.

    Definition Classes
    Observable
  139. def subscribe(nextFn: (T) ⇒ Future[Ack], errorFn: (Throwable) ⇒ Unit, completedFn: () ⇒ Unit)(implicit s: Scheduler): BooleanCancelable

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    returns

    a subscription that can be used to cancel the streaming.

    Definition Classes
    Observable
  140. def subscribe(observer: Observer[T])(implicit s: Scheduler): BooleanCancelable

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    returns

    a subscription that can be used to cancel the streaming.

    Definition Classes
    Observable
  141. def subscribe(subscriber: Subscriber[T]): BooleanCancelable

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    returns

    a subscription that can be used to cancel the streaming.

    Definition Classes
    Observable
  142. def subscribeOn(s: Scheduler): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  143. def sum[U >: T](implicit ev: Numeric[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  144. def switch[U](implicit ev: <:<[T, Observable[U]]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  145. def switchMap[U](f: (T) ⇒ Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  146. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  147. def tail: ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  148. def take(timespan: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  149. def take(n: Long): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  150. def takeRight(n: Int): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  151. def takeWhile(p: (T) ⇒ Boolean): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  152. def takeWhileNotCanceled(c: BooleanCancelable): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  153. def throttleFirst(interval: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  154. def throttleLast(period: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  155. def throttleWithTimeout(timeout: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  156. def timeout[U >: T](timeout: FiniteDuration, backup: Observable[U]): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  157. def timeout(timeout: FiniteDuration): ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  158. def toReactive[U >: T](implicit s: Scheduler): Publisher[U]

    Permalink

    Wraps this Observable into a org.reactivestreams.Publisher.

    Wraps this Observable into a org.reactivestreams.Publisher. See the Reactive Streams protocol that Monifu implements.

    Definition Classes
    Observable
  159. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  160. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  161. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  162. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  163. def whileBusyBuffer[U >: T](overflowStrategy: Evicted, onOverflow: (Long) ⇒ U): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  164. def whileBusyBuffer[U >: T](overflowStrategy: Synchronous): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  165. def whileBusyDropEvents[U >: T](onOverflow: (Long) ⇒ U): ObservableChannel[T, U]

    Permalink
    Definition Classes
    LiftOperators2
  166. def whileBusyDropEvents: ObservableChannel[T, T]

    Permalink
    Definition Classes
    LiftOperators2
  167. def window(timespan: FiniteDuration, maxCount: Int): ObservableChannel[T, Observable[T]]

    Permalink
    Definition Classes
    LiftOperators2
  168. def window(timespan: FiniteDuration): ObservableChannel[T, Observable[T]]

    Permalink
    Definition Classes
    LiftOperators2
  169. def window(count: Int, skip: Int): ObservableChannel[T, Observable[T]]

    Permalink
    Definition Classes
    LiftOperators2
  170. def window(count: Int): ObservableChannel[T, Observable[T]]

    Permalink
    Definition Classes
    LiftOperators2
  171. def zip[U](other: Observable[U]): ObservableChannel[T, (T, U)]

    Permalink
    Definition Classes
    LiftOperators2
  172. def zipWithIndex: ObservableChannel[T, (T, Long)]

    Permalink
    Definition Classes
    LiftOperators2

Inherited from ObservableChannel[T, T]

Inherited from LiftOperators2[T, T, ObservableChannel]

Inherited from Channel[T]

Inherited from Observable[T]

Inherited from AnyRef

Inherited from Any

Ungrouped