Path Lines of Code core/src/main/protobuf/ProjectionMessages.proto 45 core/src/main/scala/org/apache/pekko/projection/BySlicesSourceProvider.scala 5 core/src/main/scala/org/apache/pekko/projection/HandlerRecoveryStrategy.scala 34 core/src/main/scala/org/apache/pekko/projection/MergeableOffset.scala 4 core/src/main/scala/org/apache/pekko/projection/OffsetVerification.scala 16 core/src/main/scala/org/apache/pekko/projection/Projection.scala 68 core/src/main/scala/org/apache/pekko/projection/ProjectionBehavior.scala 202 core/src/main/scala/org/apache/pekko/projection/ProjectionContext.scala 2 core/src/main/scala/org/apache/pekko/projection/ProjectionId.scala 28 core/src/main/scala/org/apache/pekko/projection/StatusObserver.scala 16 core/src/main/scala/org/apache/pekko/projection/internal/ActorHandlerInit.scala 20 core/src/main/scala/org/apache/pekko/projection/internal/HandlerAdapter.scala 58 core/src/main/scala/org/apache/pekko/projection/internal/HandlerRecoveryImpl.scala 144 core/src/main/scala/org/apache/pekko/projection/internal/InternalProjection.scala 7 core/src/main/scala/org/apache/pekko/projection/internal/InternalProjectionState.scala 404 core/src/main/scala/org/apache/pekko/projection/internal/NoopStatusObserver.scala 20 core/src/main/scala/org/apache/pekko/projection/internal/OffsetSerialization.scala 81 core/src/main/scala/org/apache/pekko/projection/internal/OffsetStrategy.scala 80 core/src/main/scala/org/apache/pekko/projection/internal/ProjectionContextImpl.scala 17 core/src/main/scala/org/apache/pekko/projection/internal/ProjectionSerializer.scala 142 core/src/main/scala/org/apache/pekko/projection/internal/ProjectionSettings.scala 93 core/src/main/scala/org/apache/pekko/projection/internal/SourceProviderAdapter.scala 26 core/src/main/scala/org/apache/pekko/projection/internal/Telemetry.scala 71 core/src/main/scala/org/apache/pekko/projection/javadsl/ActorHandler.scala 15 core/src/main/scala/org/apache/pekko/projection/javadsl/Handler.scala 29 core/src/main/scala/org/apache/pekko/projection/javadsl/ProjectionManagement.scala 31 core/src/main/scala/org/apache/pekko/projection/javadsl/Projections.scala 87 core/src/main/scala/org/apache/pekko/projection/javadsl/SourceProvider.scala 22 core/src/main/scala/org/apache/pekko/projection/javadsl/StatefulHandler.scala 31 core/src/main/scala/org/apache/pekko/projection/scaladsl/ActorHandler.scala 14 core/src/main/scala/org/apache/pekko/projection/scaladsl/Handler.scala 36 core/src/main/scala/org/apache/pekko/projection/scaladsl/ProjectionManagement.scala 96 core/src/main/scala/org/apache/pekko/projection/scaladsl/Projections.scala 86 core/src/main/scala/org/apache/pekko/projection/scaladsl/SourceProvider.scala 20 core/src/main/scala/org/apache/pekko/projection/scaladsl/StatefulHandler.scala 31