Packages

package stream

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. trait AkkaPiObservable[T] extends PiObservable[T]
  2. trait AkkaPiStream[T] extends PiPublisher[T]
  3. case class AkkaPiSwitch(pub: ActorRef, sub: ActorRef) extends PiSwitch with Product with Serializable
  4. class CounterHandler[T] extends PromiseHandler[T, Int]
  5. class CounterHandlerFactory[T] extends PiEventHandlerFactory[T, CounterHandler[T]]
  6. trait DelegatedPiObservable[T] extends PiObservable[T]
  7. case class MultiPiEventHandler[T](handlers: Queue[PiEventHandler[T]]) extends PiEventHandler[T] with Product with Serializable

    A PiEventHandler consisting of a queue of multiple handlers.

  8. trait PiEventHandler[KeyT] extends (PiEvent[KeyT]) ⇒ Boolean

    A listener for PiEvents.

  9. trait PiEventHandlerFactory[T, H <: PiEventHandler[T]] extends AnyRef

    A factory that generates a handler that is related to a particular workflow ID.

    A factory that generates a handler that is related to a particular workflow ID. The ID is generated by the com.workflowfm.pew.execution.ProcessExecutor so we do not know it in advance.

  10. trait PiObservable[T] extends AnyRef

    Anything that can be observed by a PiEventHandler.

    Anything that can be observed by a PiEventHandler. This is separate from PiPublisher as in some cases publishing events and handling listeners happens in 2 different places.

  11. trait PiPublisher[T] extends AnyRef

    Has the ability to publish PiEvents.

    Has the ability to publish PiEvents. This is separate from PiObservable as in some cases publishing events and handling listeners happens in 2 different places.

  12. class PiSubscriber[T] extends Actor
  13. trait PiSwitch extends AnyRef

    A kill switch allowing us to stop a PiEventHandler.

  14. class PrintEventHandler[T] extends PiEventHandler[T]

    Example of a PiEventHandler that simply prints a string representation of the event to System.err.

  15. trait PromiseHandler[T, R] extends PiEventHandler[T]
  16. class ResultHandler[T] extends PromiseHandler[T, Any]
  17. class ResultHandlerFactory[T] extends PiEventHandlerFactory[T, ResultHandler[T]]
  18. trait SimplePiObservable[T] extends PiObservable[T] with PiPublisher[T]

    A simple PiObservable and PiPublisher with a mutable map of handlers.

Value Members

  1. object AkkaPiStream
  2. object MultiPiEventHandler extends Serializable
  3. object PiSubscriber

Ungrouped