Packages

abstract class SimpleProcessor[FROM, TO] extends Processor[FROM, TO] with Parent[TO]

Linear Supertypes
Parent[TO], Processor[FROM, TO], Publisher[TO], Subscriber[FROM], AnyRef, Any
Known Subclasses
StubEventProcessor
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SimpleProcessor
  2. Parent
  3. Processor
  4. Publisher
  5. Subscriber
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SimpleProcessor(subscriptionUpdateDelay: Duration = 3.seconds)(implicit scheduler: Scheduler, executionContext: ExecutionContext)

Abstract Value Members

  1. abstract def ftransform(recorded: FROM): Failable[TO]

Concrete Value Members

  1. def onComplete(): Unit
    Definition Classes
    SimpleProcessor → Subscriber
  2. def onError(t: Throwable): Unit
    Definition Classes
    SimpleProcessor → Subscriber
  3. def onNext(recorded: FROM): Unit
    Definition Classes
    SimpleProcessor → Subscriber
  4. def onSubscribe(subscription: Subscription): Unit
    Definition Classes
    SimpleProcessor → Subscriber
  5. def subscribe(s: Subscriber[_ >: TO]): Unit
    Definition Classes
    SimpleProcessor → Publisher