ProjectionHandler

works.iterative.pekko.ProjectionHandler
class ProjectionHandler[E, J](dbConfig: DatabaseConfig[MySQLProfile], processor: ViewProcessor[E], transform: J => E)(using runtime: Runtime[Any]) extends SlickHandler[EventEnvelope[J]]

Attributes

Graph
Supertypes
trait SlickHandler[EventEnvelope[J]]
trait HandlerLifecycle
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

override def process(envelope: EventEnvelope[J]): DBIO[Done]

Attributes

Definition Classes
SlickHandler

Inherited methods

def start(): Future[Done]

Invoked when the projection is starting, before first envelope is processed. Can be overridden to implement initialization. It is also called when the Projection is restarted after a failure.

Invoked when the projection is starting, before first envelope is processed. Can be overridden to implement initialization. It is also called when the Projection is restarted after a failure.

Attributes

Inherited from:
HandlerLifecycle
def stop(): Future[Done]

Invoked when the projection has been stopped. Can be overridden to implement resource cleanup. It is also called when the Projection is restarted after a failure.

Invoked when the projection has been stopped. Can be overridden to implement resource cleanup. It is also called when the Projection is restarted after a failure.

Attributes

Inherited from:
HandlerLifecycle