Packages

t

akka.projection.grpc.replication.javadsl

ReplicationProjectionProvider

trait ReplicationProjectionProvider extends AnyRef

Factory for creating the projection where offsets are kept track of for the replication streams

Annotations
@ApiMayChange() @FunctionalInterface()
Source
ReplicationProjectionProvider.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ReplicationProjectionProvider
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def create(projectionId: ProjectionId, sourceProvider: SourceProvider[Offset, EventEnvelope[AnyRef]], replicationFlow: FlowWithContext[EventEnvelope[AnyRef], ProjectionContext, Done, ProjectionContext, NotUsed], system: ActorSystem[_]): AtLeastOnceFlowProjection[Offset, EventEnvelope[AnyRef]]