impl

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.