Packages

class Processor extends SimpleProcessor[(SolidityEvent, Metadata), DeedClosed]

Linear Supertypes
SimpleProcessor[(SolidityEvent, Metadata), DeedClosed], Parent[DeedClosed], org.reactivestreams.Processor[(SolidityEvent, Metadata), DeedClosed], Publisher[DeedClosed], Subscriber[(SolidityEvent, Metadata)], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Processor
  2. SimpleProcessor
  3. Parent
  4. Processor
  5. Publisher
  6. Subscriber
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Processor()(implicit scheduler: Scheduler, executionContext: ExecutionContext)

Value Members

  1. def ftransform(pair: (SolidityEvent, Metadata)): Failable[DeedClosed]
    Definition Classes
    Processor → SimpleProcessor
  2. def onComplete(): Unit
    Definition Classes
    SimpleProcessor → Subscriber
  3. def onError(t: Throwable): Unit
    Definition Classes
    SimpleProcessor → Subscriber
  4. def onNext(recorded: (SolidityEvent, Metadata)): Unit
    Definition Classes
    SimpleProcessor → Subscriber
  5. def onSubscribe(subscription: Subscription): Unit
    Definition Classes
    SimpleProcessor → Subscriber
  6. def subscribe(s: Subscriber[_ >: DeedClosed]): Unit
    Definition Classes
    SimpleProcessor → Publisher