Packages

c

com.lightbend.lagom.scaladsl.testkit

ReadSideTestDriver

class ReadSideTestDriver extends ReadSide

Source
ReadSideTestDriver.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ReadSideTestDriver
  2. ReadSide
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ReadSideTestDriver()(implicit materializer: Materializer, ec: ExecutionContext)

Value Members

  1. def feed[Event <: AggregateEvent[Event]](entityId: String, event: Event, offset: Offset): Future[Done]
  2. implicit val materializer: Materializer
  3. def register[Event <: AggregateEvent[Event]](processorFactory: ⇒ ReadSideProcessor[Event]): Unit

    Register a read-side processor with Lagom.

    Register a read-side processor with Lagom.

    * The processorFactory will be called when a new processor instance is to be created. That will happen in another thread, so the processorFactory must be thread-safe, e.g. not close over shared mutable state that is not thread-safe.

    Definition Classes
    ReadSideTestDriverReadSide