com.lightbend.lagom.javadsl.testkit

Class ReadSideTestDriver

Object

com.lightbend.lagom.javadsl.testkit.ReadSideTestDriver

All Implemented Interfaces:

ReadSide

public class ReadSideTestDriver
extends Object
implements ReadSide

Constructor Summary

Constructors

Constructor and Description
ReadSideTestDriver(com.google.inject.Injector injector, akka.stream.Materializer materializer)

Method Summary

Modifier and Type	Method and Description
<Event extends AggregateEvent<Event>> CompletionStage<akka.Done>	feed(Event e, Offset offset)
<Event extends AggregateEvent<Event>> void	register(Class<? extends ReadSideProcessor<Event>> processorClass) Register a read-side processor with Lagom.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReadSideTestDriver

@Inject
public ReadSideTestDriver(com.google.inject.Injector injector,
                                  akka.stream.Materializer materializer)

Method Detail

register

public <Event extends AggregateEvent<Event>> void register(Class<? extends ReadSideProcessor<Event>> processorClass)

Description copied from interface: ReadSide

Register a read-side processor with Lagom.

Specified by:

register in interface ReadSide

Parameters:

processorClass - The read-side processor class to register. It will be instantiated using Guice, once for every shard that runs it. Typically it should not be a singleton.

feed

public <Event extends AggregateEvent<Event>> CompletionStage<akka.Done> feed(Event e,
                                                                             Offset offset)