Packages

trait Publisher[T] extends Any

Mirrors the Publisher interface from the Reactive Streams project.

A Publisher is a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from its Subscribers.

A Publisher can serve multiple Subscribers subscribed dynamically at various points in time.

Linear Supertypes
Any
Known Subclasses
Processor
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Publisher
  2. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def getClass(): Class[_]
    Definition Classes
    Any
  2. abstract def subscribe(subscriber: Subscriber[_ >: T]): Unit

    Request the publisher to start emitting data.

    Request the publisher to start emitting data.

    This is a factory method and can be called multiple times, each time starting a new Subscription. Each Subscription will work for only a single Subscriber. A Subscriber should only subscribe once to a single Publisher.

    If the Publisher rejects the subscription attempt or otherwise fails it will signal the error via Subscriber.onError.

    subscriber

    the Subscriber that will consume signals from this Publisher

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    Any
  2. final def ##(): Int
    Definition Classes
    Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def equals(arg0: Any): Boolean
    Definition Classes
    Any
  6. def hashCode(): Int
    Definition Classes
    Any
  7. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  8. def toString(): String
    Definition Classes
    Any

Inherited from Any

Ungrouped