package impl

  1. Public
  2. All

Type Members

  1. final class PublisherEnumerator[T] extends Enumerator[T]

    Adapts a Publisher to an Enumerator.

    Adapts a Publisher to an Enumerator.

    When an Iteratee is applied to the Enumerator, we adapt the Iteratee into a Subscriber, then subscribe it to the Publisher.

  2. final class SubscriberPublisherProcessor[T, U] extends Processor[T, U]

    Very simple Processor that delegates to its Subscriber and Publisher arguments.

  3. trait SubscriptionHandle[U] extends AnyRef

    Wraps a Subscription created by a SubscriptionFactory, allowing the Subscription to be started and queried.