Packages

c

com.avsystem.commons.mongo.async

MongoObservableReactivePublisher

final class MongoObservableReactivePublisher[T] extends Publisher[T]

Linear Supertypes
Publisher[T], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MongoObservableReactivePublisher
  2. Publisher
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MongoObservableReactivePublisher(observable: Observable[T])

Value Members

  1. def subscribe(subscriber: Subscriber[_ >: T]): Unit
    Definition Classes
    MongoObservableReactivePublisher → Publisher