- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Documentation path like ".*/docs/.*" 931 files: cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorDocSpec.scala cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/PingSerializer.scala cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/BasicClusterExampleSpec.scala cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/ReceptionistExample.scala cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/SingletonCompileOnlySpec.scala cluster-typed/src/test/scala/docs/org/apache/pekko/cluster/typed/DistributedPubSubExample.scala osgi/src/test/scala/docs/osgi/Activator.scala actor-testkit-typed/src/test/scala/docs/org/apache/pekko/actor/testkit/typed/scaladsl/SyncTestingExampleSpec.scala actor-testkit-typed/src/test/scala/docs/org/apache/pekko/actor/testkit/typed/scaladsl/ScalaTestIntegrationExampleSpec.scala actor-testkit-typed/src/test/scala/docs/org/apache/pekko/actor/testkit/typed/scaladsl/ManualTimerExampleSpec.scala actor-testkit-typed/src/test/scala/docs/org/apache/pekko/actor/testkit/typed/scaladsl/AsyncTestingExampleSpec.scala actor-testkit-typed/src/test/scala/docs/org/apache/pekko/actor/testkit/typed/scaladsl/TestConfigExample.scala docs/src/test/scala-jdk9-only/docs/stream/operators/source/AsSubscriber.scala docs/src/test/scala-jdk9-only/docs/stream/operators/source/FromPublisher.scala docs/src/test/resources/logback-test.xml docs/src/test/java-jdk9-only/jdocs/stream/operators/source/FromPublisher.java docs/src/test/java-jdk9-only/jdocs/stream/operators/source/AsSubscriber.java docs/src/test/java/jdocs/remoting/RemoteDeploymentDocTest.java docs/src/test/java/jdocs/cluster/StatsService.java docs/src/test/java/jdocs/cluster/StatsMessages.java docs/src/test/java/jdocs/cluster/FactorialFrontend.java docs/src/test/java/jdocs/cluster/StatsWorker.java docs/src/test/java/jdocs/cluster/FactorialResult.java docs/src/test/java/jdocs/cluster/StatsAggregator.java docs/src/test/java/jdocs/cluster/MetricsListener.java docs/src/test/java/jdocs/cluster/TransformationFrontend.java docs/src/test/java/jdocs/cluster/TransformationBackend.java docs/src/test/java/jdocs/cluster/TransformationMessages.java docs/src/test/java/jdocs/cluster/ClusterDocTest.java docs/src/test/java/jdocs/cluster/StatsSampleOneMasterMain.java docs/src/test/java/jdocs/cluster/singleton/SupervisorActor.java docs/src/test/java/jdocs/cluster/singleton/ClusterSingletonSupervision.java docs/src/test/java/jdocs/cluster/FactorialFrontendMain.java docs/src/test/java/jdocs/cluster/SimpleClusterListener2.java docs/src/test/java/jdocs/cluster/StatsSampleOneMasterClientMain.java docs/src/test/java/jdocs/cluster/FactorialBackend.java docs/src/test/java/jdocs/cluster/SimpleClusterListener.java docs/src/test/java/jdocs/cluster/StatsSampleClient.java docs/src/test/java/jdocs/extension/ExtensionDocTest.java docs/src/test/java/jdocs/extension/SettingsExtensionDocTest.java docs/src/test/java/jdocs/coordination/LeaseDocTest.java docs/src/test/java/jdocs/config/ConfigDocTest.java docs/src/test/java/jdocs/serialization/SerializationDocTest.java docs/src/test/java/jdocs/stream/StreamTestKitDocTest.java docs/src/test/java/jdocs/stream/RestartDocTest.java docs/src/test/java/jdocs/stream/BidiFlowDocTest.java docs/src/test/java/jdocs/stream/FlowParallelismDocTest.java docs/src/test/java/jdocs/stream/GraphCyclesDocTest.java docs/src/test/java/jdocs/stream/ReactiveStreamsDocTest.java docs/src/test/java/jdocs/stream/operators/sourceorflow/Sliding.java docs/src/test/java/jdocs/stream/operators/sourceorflow/MapConcat.java docs/src/test/java/jdocs/stream/operators/sourceorflow/Split.java docs/src/test/java/jdocs/stream/operators/sourceorflow/Intersperse.java docs/src/test/java/jdocs/stream/operators/sourceorflow/LimitWeighted.java docs/src/test/java/jdocs/stream/operators/sourceorflow/Limit.java docs/src/test/java/jdocs/stream/operators/sourceorflow/MapAsyncs.java docs/src/test/java/jdocs/stream/operators/sourceorflow/FlatMapConcat.java docs/src/test/java/jdocs/stream/operators/sourceorflow/Throttle.java docs/src/test/java/jdocs/stream/operators/sourceorflow/MapError.java docs/src/test/java/jdocs/stream/operators/sourceorflow/FlatMapMerge.java docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java docs/src/test/java/jdocs/stream/operators/sourceorflow/ExtrapolateAndExpand.java docs/src/test/java/jdocs/stream/operators/sourceorflow/MergeLatest.java docs/src/test/java/jdocs/stream/operators/SourceDocExamples.java docs/src/test/java/jdocs/stream/operators/WithContextTest.java docs/src/test/java/jdocs/stream/operators/source/FromCompletionStage.java docs/src/test/java/jdocs/stream/operators/source/UnfoldResourceAsync.java docs/src/test/java/jdocs/stream/operators/source/Unfold.java docs/src/test/java/jdocs/stream/operators/source/Restart.java docs/src/test/java/jdocs/stream/operators/source/UnfoldAsync.java docs/src/test/java/jdocs/stream/operators/source/Tick.java docs/src/test/java/jdocs/stream/operators/source/Zip.java docs/src/test/java/jdocs/stream/operators/source/Combine.java docs/src/test/java/jdocs/stream/operators/source/Lazy.java docs/src/test/java/jdocs/stream/operators/source/From.java docs/src/test/java/jdocs/stream/operators/source/CompletionStageSource.java docs/src/test/java/jdocs/stream/operators/source/UnfoldResource.java docs/src/test/java/jdocs/stream/operators/converters/StreamConvertersToJava.java docs/src/test/java/jdocs/stream/operators/converters/ToFromJavaIOStreams.java docs/src/test/java/jdocs/stream/operators/sink/Lazy.java docs/src/test/java/jdocs/stream/operators/PartitionDocExample.java docs/src/test/java/jdocs/stream/operators/MergeSequenceDocExample.java docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java docs/src/test/java/jdocs/stream/operators/SinkDocExamples.java docs/src/test/java/jdocs/stream/operators/BroadcastDocExample.java docs/src/test/java/jdocs/stream/operators/flow/FromSinkAndSource.java docs/src/test/java/jdocs/stream/operators/flow/StatefulMapConcat.java docs/src/test/java/jdocs/stream/operators/flow/FutureFlow.java docs/src/test/java/jdocs/stream/operators/flow/Lazy.java docs/src/test/java/jdocs/stream/operators/flow/StatefulMap.java docs/src/test/java/jdocs/stream/GraphStageDocTest.java docs/src/test/java/jdocs/stream/FlowStreamRefsDocTest.java docs/src/test/java/jdocs/stream/SilenceSystemOut.java docs/src/test/java/jdocs/stream/io/StreamFileDocTest.java docs/src/test/java/jdocs/stream/io/StreamTcpDocTest.java docs/src/test/java/jdocs/stream/QuickStartDocTest.java docs/src/test/java/jdocs/stream/StreamPartialGraphDSLDocTest.java docs/src/test/java/jdocs/stream/StreamBuffersRateDocTest.java docs/src/test/java/jdocs/stream/MigrationsJava.java docs/src/test/java/jdocs/stream/GraphStageLoggingDocTest.java docs/src/test/java/jdocs/stream/HubDocTest.java docs/src/test/java/jdocs/stream/CompositionDocTest.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeHold.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeManualTrigger.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeSourceFromFunction.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeSeq.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeKeepAlive.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeLoggingElements.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeMultiGroupByTest.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeDecompress.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeParseLines.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeAdhocSourceTest.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeDroppyBroadcast.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeGlobalRateLimit.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeMissedTicks.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeByteStrings.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeSimpleDrop.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeReduceByKeyTest.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeTest.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeFlattenList.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeSplitter.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeWorkerPool.java docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeDigest.java docs/src/test/java/jdocs/stream/SubstreamDocTest.java docs/src/test/java/jdocs/stream/FlowDocTest.java docs/src/test/java/jdocs/stream/TwitterStreamQuickstartDocTest.java docs/src/test/java/jdocs/stream/FlowErrorDocTest.java docs/src/test/java/jdocs/stream/RateTransformationDocTest.java docs/src/test/java/jdocs/stream/Main.java docs/src/test/java/jdocs/stream/SinkRecipeDocTest.java docs/src/test/java/jdocs/stream/IntegrationDocTest.java docs/src/test/java/jdocs/stream/KillSwitchDocTest.java docs/src/test/java/jdocs/dispatcher/MyUnboundedMessageQueueSemantics.java docs/src/test/java/jdocs/dispatcher/MyUnboundedMailbox.java docs/src/test/java/jdocs/dispatcher/DispatcherDocTest.java docs/src/test/java/jdocs/io/IODocTest.java docs/src/test/java/jdocs/io/JavaReadBackPressure.java docs/src/test/java/jdocs/io/JavaUdpMulticast.java docs/src/test/java/jdocs/io/UdpConnectedDocTest.java docs/src/test/java/jdocs/io/JavaUdpMulticastTest.java docs/src/test/java/jdocs/io/japi/Message.java docs/src/test/java/jdocs/io/japi/IODocTest.java docs/src/test/java/jdocs/io/japi/EchoHandler.java docs/src/test/java/jdocs/io/japi/EchoManager.java docs/src/test/java/jdocs/io/japi/SimpleEchoHandler.java docs/src/test/java/jdocs/io/japi/EchoServer.java docs/src/test/java/jdocs/io/japi/Watcher.java docs/src/test/java/jdocs/io/UdpDocTest.java docs/src/test/java/jdocs/discovery/DnsDiscoveryDocTest.java docs/src/test/java/jdocs/ddata/TwoPhaseSet.java docs/src/test/java/jdocs/ddata/DataBot.java docs/src/test/java/jdocs/ddata/DistributedDataDocTest.java docs/src/test/java/jdocs/ddata/ShoppingCart.java docs/src/test/java/jdocs/ddata/protobuf/TwoPhaseSetSerializerWithCompression.java docs/src/test/java/jdocs/ddata/protobuf/TwoPhaseSetSerializer2.java docs/src/test/java/jdocs/ddata/protobuf/TwoPhaseSetSerializer.java docs/src/test/java/jdocs/sharding/ClusterShardingTest.java docs/src/test/java/jdocs/testkit/ParentChildTest.java docs/src/test/java/jdocs/testkit/TestKitSampleTest.java docs/src/test/java/jdocs/testkit/TestKitDocTest.java docs/src/test/java/jdocs/persistence/PersistentActorExample.java docs/src/test/java/jdocs/persistence/PersistenceMultiDocTest.java docs/src/test/java/jdocs/persistence/PersistenceQueryDocTest.java docs/src/test/java/jdocs/persistence/testkit/Configuration.java docs/src/test/java/jdocs/persistence/testkit/PersistenceTestKitPolicySampleTest.java docs/src/test/java/jdocs/persistence/testkit/PersistenceInitTest.java docs/src/test/java/jdocs/persistence/testkit/TestKitExamples.java docs/src/test/java/jdocs/persistence/testkit/PersistenceTestKitSampleTest.java docs/src/test/java/jdocs/persistence/PersistenceEventAdapterDocTest.java docs/src/test/java/jdocs/persistence/LambdaPersistencePluginDocTest.java docs/src/test/java/jdocs/persistence/PersistenceSchemaEvolutionDocTest.java docs/src/test/java/jdocs/persistence/query/LeveldbPersistenceQueryDocTest.java docs/src/test/java/jdocs/persistence/query/MyEventsByTagSource.java docs/src/test/java/jdocs/persistence/LambdaPersistenceDocTest.java docs/src/test/java/jdocs/typed/tutorial_2/IotMain.java docs/src/test/java/jdocs/typed/tutorial_2/IotSupervisor.java docs/src/test/java/jdocs/typed/tutorial_5/DeviceTest.java docs/src/test/java/jdocs/typed/tutorial_5/DeviceGroupTest.java docs/src/test/java/jdocs/typed/tutorial_5/Device.java docs/src/test/java/jdocs/typed/tutorial_5/DeviceManager.java docs/src/test/java/jdocs/typed/tutorial_5/DeviceGroup.java docs/src/test/java/jdocs/typed/tutorial_5/DeviceGroupQuery.java docs/src/test/java/jdocs/typed/tutorial_5/DeviceManagerTest.java docs/src/test/java/jdocs/typed/tutorial_5/DeviceGroupQueryTest.java docs/src/test/java/jdocs/typed/tutorial_4/DeviceTest.java docs/src/test/java/jdocs/typed/tutorial_4/DeviceGroupTest.java docs/src/test/java/jdocs/typed/tutorial_4/Device.java docs/src/test/java/jdocs/typed/tutorial_4/DeviceManager.java docs/src/test/java/jdocs/typed/tutorial_4/DeviceGroup.java docs/src/test/java/jdocs/typed/tutorial_4/DeviceManagerTest.java docs/src/test/java/jdocs/typed/tutorial_3/inprogress2/Device.java docs/src/test/java/jdocs/typed/tutorial_3/inprogress3/Device.java docs/src/test/java/jdocs/typed/tutorial_3/inprogress1/Device.java docs/src/test/java/jdocs/typed/tutorial_3/DeviceTest.java docs/src/test/java/jdocs/typed/tutorial_3/Device.java docs/src/test/java/jdocs/typed/tutorial_1/ActorHierarchyExperiments.java docs/src/test/java/jdocs/AbstractJavaTest.java docs/src/test/java/jdocs/routing/RedundancyGroup.java docs/src/test/java/jdocs/routing/RouterDocTest.java docs/src/test/java/jdocs/routing/CustomRouterDocTest.java docs/src/test/java/jdocs/routing/ConsistentHashingRouterDocTest.java docs/src/test/java/jdocs/pattern/BackoffSupervisorDocTest.java docs/src/test/java/jdocs/pattern/SupervisedAsk.java docs/src/test/java/jdocs/pattern/SupervisedAskSpec.java docs/src/test/java/jdocs/duration/Java.java docs/src/test/java/jdocs/circuitbreaker/EvenNoFailureJavaExample.java docs/src/test/java/jdocs/circuitbreaker/TellPatternJavaActor.java docs/src/test/java/jdocs/circuitbreaker/DangerousJavaActor.java docs/src/test/java/jdocs/actor/GraduallyBuiltActor.java docs/src/test/java/jdocs/actor/SchedulerDocTest.java docs/src/test/java/jdocs/actor/TimerDocTest.java docs/src/test/java/jdocs/actor/FaultHandlingDocSample.java docs/src/test/java/jdocs/actor/io/dns/DnsCompileOnlyDocTest.java docs/src/test/java/jdocs/actor/SampleActor.java docs/src/test/java/jdocs/actor/ByteBufferSerializerDocTest.java docs/src/test/java/jdocs/actor/fsm/FSMDocTest.java docs/src/test/java/jdocs/actor/fsm/BuncherTest.java docs/src/test/java/jdocs/actor/fsm/Events.java docs/src/test/java/jdocs/actor/fsm/Buncher.java docs/src/test/java/jdocs/actor/MyBoundedActor.java docs/src/test/java/jdocs/actor/InitializationDocTest.java docs/src/test/java/jdocs/actor/MyActor.java docs/src/test/java/jdocs/actor/ActorDocTest.java docs/src/test/java/jdocs/actor/Messages.java docs/src/test/java/jdocs/actor/typed/SeparateDispatcherCompletionStageActor.java docs/src/test/java/jdocs/actor/typed/BlockingDispatcherTest.java docs/src/test/java/jdocs/actor/typed/PrintActor.java docs/src/test/java/jdocs/actor/typed/BlockingActor.java docs/src/test/java/jdocs/actor/typed/SharedMutableStateDocTest.java docs/src/test/java/jdocs/actor/typed/CoordinatedActorShutdownTest.java docs/src/test/java/jdocs/actor/typed/DispatcherDocTest.java docs/src/test/java/jdocs/actor/FaultHandlingTest.java docs/src/test/java/jdocs/actor/SampleActorTest.java docs/src/test/java/jdocs/actor/MyStoppingActor.java docs/src/test/java/jdocs/actor/DependencyInjectionDocTest.java docs/src/test/java/jdocs/actor/ImmutableMessage.java docs/src/test/java/jdocs/event/EventBusDocTest.java docs/src/test/java/jdocs/event/LoggingDocTest.java docs/src/test/java/jdocs/future/ActorWithFuture.java docs/src/test/java/jdocs/future/FutureDocTest.java docs/src/test/scala/docs/remoting/RemoteDeploymentDocSpec.scala docs/src/test/scala/docs/cluster/TransformationMessages.scala docs/src/test/scala/docs/cluster/FactorialFrontend.scala docs/src/test/scala/docs/cluster/TransformationFrontend.scala docs/src/test/scala/docs/cluster/SimpleClusterListener2.scala docs/src/test/scala/docs/cluster/ClusterDocSpec.scala docs/src/test/scala/docs/cluster/TransformationBackend.scala docs/src/test/scala/docs/cluster/SimpleClusterListener.scala docs/src/test/scala/docs/cluster/singleton/ClusterSingletonSupervision.scala docs/src/test/scala/docs/cluster/FactorialBackend.scala docs/src/test/scala/docs/cluster/MetricsListener.scala docs/src/test/scala/docs/extension/ExtensionDocSpec.scala docs/src/test/scala/docs/extension/SettingsExtensionDocSpec.scala docs/src/test/scala/docs/coordination/LeaseDocSpec.scala docs/src/test/scala/docs/config/ConfigDocSpec.scala docs/src/test/scala/docs/faq/Faq.scala docs/src/test/scala/docs/serialization/SerializationDocSpec.scala docs/src/test/scala/docs/stream/GraphStageDocSpec.scala docs/src/test/scala/docs/stream/TwitterStreamQuickstartDocSpec.scala docs/src/test/scala/docs/stream/HubsDocSpec.scala docs/src/test/scala/docs/stream/CompositionDocSpec.scala docs/src/test/scala/docs/stream/GraphStageLoggingDocSpec.scala docs/src/test/scala/docs/stream/operators/BroadcastDocExample.scala docs/src/test/scala/docs/stream/operators/sourceorflow/GroupedWeighted.scala docs/src/test/scala/docs/stream/operators/sourceorflow/GroupBy.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Log.scala docs/src/test/scala/docs/stream/operators/sourceorflow/LimitWeighted.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Take.scala docs/src/test/scala/docs/stream/operators/sourceorflow/ExtrapolateAndExpand.scala docs/src/test/scala/docs/stream/operators/sourceorflow/FoldAsync.scala docs/src/test/scala/docs/stream/operators/sourceorflow/TakeWhile.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Split.scala docs/src/test/scala/docs/stream/operators/sourceorflow/MapAsyncs.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Limit.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Fold.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Throttle.scala docs/src/test/scala/docs/stream/operators/sourceorflow/ScanAsync.scala docs/src/test/scala/docs/stream/operators/sourceorflow/WatchTermination.scala docs/src/test/scala/docs/stream/operators/sourceorflow/FlatMapMerge.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Intersperse.scala docs/src/test/scala/docs/stream/operators/sourceorflow/MergeLatest.scala docs/src/test/scala/docs/stream/operators/sourceorflow/CompletionTimeout.scala docs/src/test/scala/docs/stream/operators/sourceorflow/LogWithMarker.scala docs/src/test/scala/docs/stream/operators/sourceorflow/FlatMapConcat.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Sliding.scala docs/src/test/scala/docs/stream/operators/sourceorflow/MapConcat.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Conflate.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Reduce.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Monitor.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Filter.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Grouped.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Collect.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Drop.scala docs/src/test/scala/docs/stream/operators/sourceorflow/MapError.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Scan.scala docs/src/test/scala/docs/stream/operators/sourceorflow/Watch.scala docs/src/test/scala/docs/stream/operators/source/Unfold.scala docs/src/test/scala/docs/stream/operators/source/UnfoldAsync.scala docs/src/test/scala/docs/stream/operators/source/FutureSource.scala docs/src/test/scala/docs/stream/operators/source/From.scala docs/src/test/scala/docs/stream/operators/source/Restart.scala docs/src/test/scala/docs/stream/operators/source/UnfoldResourceAsync.scala docs/src/test/scala/docs/stream/operators/source/Tick.scala docs/src/test/scala/docs/stream/operators/source/Zip.scala docs/src/test/scala/docs/stream/operators/source/Combine.scala docs/src/test/scala/docs/stream/operators/source/Lazy.scala docs/src/test/scala/docs/stream/operators/source/UnfoldResource.scala docs/src/test/scala/docs/stream/operators/converters/StreamConvertersToJava.scala docs/src/test/scala/docs/stream/operators/converters/ToFromJavaIOStreams.scala docs/src/test/scala/docs/stream/operators/sink/Collection.scala docs/src/test/scala/docs/stream/operators/sink/Ignore.scala docs/src/test/scala/docs/stream/operators/sink/Fold.scala docs/src/test/scala/docs/stream/operators/sink/HeadOption.scala docs/src/test/scala/docs/stream/operators/sink/AsPublisher.scala docs/src/test/scala/docs/stream/operators/sink/Lazy.scala docs/src/test/scala/docs/stream/operators/sink/Cancelled.scala docs/src/test/scala/docs/stream/operators/MergeSequenceDocExample.scala docs/src/test/scala/docs/stream/operators/PartitionDocExample.scala docs/src/test/scala/docs/stream/operators/Map.scala docs/src/test/scala/docs/stream/operators/WithContextSpec.scala docs/src/test/scala/docs/stream/operators/SourceOperators.scala docs/src/test/scala/docs/stream/operators/flow/StatefulMapConcat.scala docs/src/test/scala/docs/stream/operators/flow/StatefulMap.scala docs/src/test/scala/docs/stream/operators/flow/FutureFlow.scala docs/src/test/scala/docs/stream/operators/flow/FromSinkAndSource.scala docs/src/test/scala/docs/stream/operators/flow/Lazy.scala docs/src/test/scala/docs/stream/FlowStreamRefsDocSpec.scala docs/src/test/scala/docs/stream/SubstreamDocSpec.scala docs/src/test/scala/docs/stream/BidiFlowDocSpec.scala docs/src/test/scala/docs/stream/RestartDocSpec.scala docs/src/test/scala/docs/stream/io/StreamTcpDocSpec.scala docs/src/test/scala/docs/stream/io/StreamFileDocSpec.scala docs/src/test/scala/docs/stream/MigrationsScala.scala docs/src/test/scala/docs/stream/QuickStartDocSpec.scala docs/src/test/scala/docs/stream/StreamTestKitDocSpec.scala docs/src/test/scala/docs/stream/FlowDocSpec.scala docs/src/test/scala/docs/stream/cookbook/RecipeFlattenSeq.scala docs/src/test/scala/docs/stream/cookbook/RecipeSimpleDrop.scala docs/src/test/scala/docs/stream/cookbook/RecipeLoggingElements.scala docs/src/test/scala/docs/stream/cookbook/RecipeMultiGroupBy.scala docs/src/test/scala/docs/stream/cookbook/RecipeSplitter.scala docs/src/test/scala/docs/stream/cookbook/RecipeGlobalRateLimit.scala docs/src/test/scala/docs/stream/cookbook/RecipeAdhocSource.scala docs/src/test/scala/docs/stream/cookbook/RecipeWorkerPool.scala docs/src/test/scala/docs/stream/cookbook/RecipeDroppyBroadcast.scala docs/src/test/scala/docs/stream/cookbook/RecipeByteStrings.scala docs/src/test/scala/docs/stream/cookbook/RecipeManualTrigger.scala docs/src/test/scala/docs/stream/cookbook/RecipeDigest.scala docs/src/test/scala/docs/stream/cookbook/RecipeMissedTicks.scala docs/src/test/scala/docs/stream/cookbook/RecipeSourceFromFunction.scala docs/src/test/scala/docs/stream/cookbook/RecipeDecompress.scala docs/src/test/scala/docs/stream/cookbook/RecipeKeepAlive.scala docs/src/test/scala/docs/stream/cookbook/RecipeHold.scala docs/src/test/scala/docs/stream/cookbook/RecipeSeq.scala docs/src/test/scala/docs/stream/cookbook/RecipeParseLines.scala docs/src/test/scala/docs/stream/cookbook/RecipeReduceByKey.scala docs/src/test/scala/docs/stream/cookbook/RecipeCollectingMetrics.scala docs/src/test/scala/docs/stream/cookbook/RecipeSpec.scala docs/src/test/scala/docs/stream/GraphCyclesSpec.scala docs/src/test/scala/docs/stream/RateTransformationDocSpec.scala docs/src/test/scala/docs/stream/FlowParallelismDocSpec.scala docs/src/test/scala/docs/stream/FlowErrorDocSpec.scala docs/src/test/scala/docs/stream/IntegrationDocSpec.scala docs/src/test/scala/docs/stream/GraphDSLDocSpec.scala docs/src/test/scala/docs/stream/StreamPartialGraphDSLDocSpec.scala docs/src/test/scala/docs/stream/KillSwitchDocSpec.scala docs/src/test/scala/docs/stream/SinkRecipeDocSpec.scala docs/src/test/scala/docs/stream/ReactiveStreamsDocSpec.scala docs/src/test/scala/docs/stream/StreamBuffersRateSpec.scala docs/src/test/scala/docs/dispatcher/DispatcherDocSpec.scala docs/src/test/scala/docs/dispatcher/MyUnboundedMailbox.scala docs/src/test/scala/docs/io/EchoServer.scala docs/src/test/scala/docs/io/ReadBackPressure.scala docs/src/test/scala/docs/io/ScalaUdpMulticast.scala docs/src/test/scala/docs/io/UdpDocSpec.scala docs/src/test/scala/docs/io/IODocSpec.scala docs/src/test/scala/docs/io/ScalaUdpMulticastSpec.scala docs/src/test/scala/docs/discovery/DnsDiscoveryDocSpec.scala docs/src/test/scala/docs/CompileOnlySpec.scala docs/src/test/scala/docs/ddata/DistributedDataDocSpec.scala docs/src/test/scala/docs/ddata/TwoPhaseSet.scala docs/src/test/scala/docs/ddata/ShoppingCart.scala docs/src/test/scala/docs/ddata/protobuf/TwoPhaseSetSerializer.scala docs/src/test/scala/docs/ddata/protobuf/TwoPhaseSetSerializer2.scala docs/src/test/scala/docs/testkit/TestkitDocSpec.scala docs/src/test/scala/docs/testkit/ParentChildSpec.scala docs/src/test/scala/docs/testkit/TestKitUsageSpec.scala docs/src/test/scala/docs/testkit/PlainWordSpec.scala docs/src/test/scala/docs/persistence/PersistenceSerializerDocSpec.scala docs/src/test/scala/docs/persistence/testkit/TestKitExamples.scala docs/src/test/scala/docs/persistence/testkit/PersistenceInitSpec.scala docs/src/test/scala/docs/persistence/testkit/Configuration.scala docs/src/test/scala/docs/persistence/PersistenceDocSpec.scala docs/src/test/scala/docs/persistence/PersistenceMultiDocSpec.scala docs/src/test/scala/docs/persistence/PersistenceSchemaEvolutionDocSpec.scala docs/src/test/scala/docs/persistence/PersistencePluginDocSpec.scala docs/src/test/scala/docs/persistence/PersistenceEventAdapterDocSpec.scala docs/src/test/scala/docs/persistence/query/LeveldbPersistenceQueryDocSpec.scala docs/src/test/scala/docs/persistence/query/MyEventsByTagSource.scala docs/src/test/scala/docs/persistence/query/PersistenceQueryDocSpec.scala docs/src/test/scala/docs/persistence/PersistentActorExample.scala docs/src/test/scala/docs/routing/CustomRouterDocSpec.scala docs/src/test/scala/docs/routing/ConsistentHashingRouterDocSpec.scala docs/src/test/scala/docs/routing/RouterDocSpec.scala docs/src/test/scala/docs/pattern/BackoffSupervisorDocSpec.scala docs/src/test/scala/docs/duration/Sample.scala docs/src/test/scala/docs/circuitbreaker/CircuitBreakerDocSpec.scala docs/src/test/scala/docs/actor/InitializationDocSpec.scala docs/src/test/scala/docs/actor/UnnestedReceives.scala docs/src/test/scala/docs/actor/TimerDocSpec.scala docs/src/test/scala/docs/actor/io/dns/DnsCompileOnlyDocSpec.scala docs/src/test/scala/docs/actor/SchedulerDocSpec.scala docs/src/test/scala/docs/actor/ActorDocSpec.scala docs/src/test/scala/docs/actor/FaultHandlingDocSample.scala docs/src/test/scala/docs/actor/FSMDocSpec.scala docs/src/test/scala/docs/actor/typed/DispatcherDocSpec.scala docs/src/test/scala/docs/actor/typed/PrintActor.scala docs/src/test/scala/docs/actor/typed/BlockingDispatcherSample.scala docs/src/test/scala/docs/actor/typed/CoordinatedActorShutdownSpec.scala docs/src/test/scala/docs/actor/typed/SharedMutableStateDocSpec.scala docs/src/test/scala/docs/actor/typed/BlockingActor.scala docs/src/test/scala/docs/actor/ByteBufferSerializerDocSpec.scala docs/src/test/scala/docs/actor/FaultHandlingDocSpec.scala docs/src/test/scala/docs/actor/SharedMutableStateDocSpec.scala docs/src/test/scala/docs/actor/PropsEdgeCaseSpec.scala docs/src/test/scala/docs/event/LoggingDocSpec.scala docs/src/test/scala/docs/event/EventBusDocSpec.scala docs/src/test/scala/docs/future/FutureDocSpec.scala docs/src/test/scala/typed/tutorial_2/IotApp.scala docs/src/test/scala/typed/tutorial_2/IotSupervisor.scala docs/src/test/scala/typed/tutorial_5/DeviceSpec.scala docs/src/test/scala/typed/tutorial_5/DeviceGroupQuery.scala docs/src/test/scala/typed/tutorial_5/DeviceManager.scala docs/src/test/scala/typed/tutorial_5/Device.scala docs/src/test/scala/typed/tutorial_5/DeviceGroup.scala docs/src/test/scala/typed/tutorial_5/DeviceManagerSpec.scala docs/src/test/scala/typed/tutorial_5/DeviceGroupQuerySpec.scala docs/src/test/scala/typed/tutorial_5/DeviceGroupSpec.scala docs/src/test/scala/typed/tutorial_4/DeviceSpec.scala docs/src/test/scala/typed/tutorial_4/DeviceManager.scala docs/src/test/scala/typed/tutorial_4/Device.scala docs/src/test/scala/typed/tutorial_4/DeviceGroup.scala docs/src/test/scala/typed/tutorial_4/DeviceManagerSpec.scala docs/src/test/scala/typed/tutorial_4/DeviceGroupSpec.scala docs/src/test/scala/typed/tutorial_3/DeviceSpec.scala docs/src/test/scala/typed/tutorial_3/Device.scala docs/src/test/scala/typed/tutorial_3/DeviceInProgress.scala docs/src/test/scala/typed/tutorial_1/ActorHierarchyExperiments.scala docs/src/main/java/docs/ddata/protobuf/msg/TwoPhaseSetMessages.java docs/src/main/java/docs/persistence/proto/FlightAppModels.java docs/src/main/paradox/coordinated-shutdown.md docs/src/main/paradox/cluster-routing.md docs/src/main/paradox/durable-state/persistence-query.md docs/src/main/paradox/cluster-dc.md docs/src/main/paradox/routing.md docs/src/main/paradox/serialization-classic.md docs/src/main/paradox/remoting.md docs/src/main/paradox/cluster-sharding.md docs/src/main/paradox/extending-pekko.md docs/src/main/paradox/index-actors.md docs/src/main/paradox/persistence-plugins.md docs/src/main/paradox/_template/projectSpecificFooter.st docs/src/main/paradox/index-utilities.md docs/src/main/paradox/remoting-artery.md docs/src/main/paradox/security/index.md docs/src/main/paradox/images/port_transitions.svg docs/src/main/paradox/images/association_lifecycle.svg docs/src/main/paradox/images/actor_lifecycle.svg docs/src/main/paradox/images/composition.svg docs/src/main/paradox/serialization.md docs/src/main/paradox/general/actor-systems.md docs/src/main/paradox/general/configuration-reference.md docs/src/main/paradox/general/remoting.md docs/src/main/paradox/general/supervision.md docs/src/main/paradox/general/stream/stream-configuration.md docs/src/main/paradox/general/message-delivery-reliability.md docs/src/main/paradox/general/addressing.md docs/src/main/paradox/general/actors.md docs/src/main/paradox/general/terminology.md docs/src/main/paradox/general/jmm.md docs/src/main/paradox/general/index.md docs/src/main/paradox/general/configuration.md docs/src/main/paradox/fsm.md docs/src/main/paradox/index-classic.md docs/src/main/paradox/coordination.md docs/src/main/paradox/stream/stream-quickstart.md docs/src/main/paradox/stream/stream-parallelism.md docs/src/main/paradox/stream/stream-customize.md docs/src/main/paradox/stream/operators/Source-or-Flow/zipLatest.md docs/src/main/paradox/stream/operators/Source-or-Flow/buffer.md docs/src/main/paradox/stream/operators/Source-or-Flow/take.md docs/src/main/paradox/stream/operators/Source-or-Flow/delay.md docs/src/main/paradox/stream/operators/Source-or-Flow/filter.md docs/src/main/paradox/stream/operators/Source-or-Flow/completionTimeout.md docs/src/main/paradox/stream/operators/Source-or-Flow/scan.md docs/src/main/paradox/stream/operators/Source-or-Flow/scanAsync.md docs/src/main/paradox/stream/operators/Source-or-Flow/splitAfter.md docs/src/main/paradox/stream/operators/Source-or-Flow/statefulMapConcat.md docs/src/main/paradox/stream/operators/Source-or-Flow/zipWith.md docs/src/main/paradox/stream/operators/Source-or-Flow/zip.md docs/src/main/paradox/stream/operators/Source-or-Flow/batchWeighted.md docs/src/main/paradox/stream/operators/Source-or-Flow/logWithMarker.md docs/src/main/paradox/stream/operators/Source-or-Flow/map.md docs/src/main/paradox/stream/operators/Source-or-Flow/prepend.md docs/src/main/paradox/stream/operators/Source-or-Flow/setup.md docs/src/main/paradox/stream/operators/Source-or-Flow/expand.md docs/src/main/paradox/stream/operators/Source-or-Flow/zipWithIndex.md docs/src/main/paradox/stream/operators/Source-or-Flow/throttle.md docs/src/main/paradox/stream/operators/Source-or-Flow/preMaterialize.md docs/src/main/paradox/stream/operators/Source-or-Flow/groupBy.md docs/src/main/paradox/stream/operators/Source-or-Flow/flatMapConcat.md docs/src/main/paradox/stream/operators/Source-or-Flow/grouped.md docs/src/main/paradox/stream/operators/Source-or-Flow/watchTermination.md docs/src/main/paradox/stream/operators/Source-or-Flow/takeWithin.md docs/src/main/paradox/stream/operators/Source-or-Flow/initialDelay.md docs/src/main/paradox/stream/operators/Source-or-Flow/recover.md docs/src/main/paradox/stream/operators/Source-or-Flow/drop.md docs/src/main/paradox/stream/operators/Source-or-Flow/fold.md docs/src/main/paradox/stream/operators/Source-or-Flow/wireTap.md docs/src/main/paradox/stream/operators/Source-or-Flow/groupedWeightedWithin.md docs/src/main/paradox/stream/operators/Source-or-Flow/delayWith.md docs/src/main/paradox/stream/operators/Source-or-Flow/watch.md docs/src/main/paradox/stream/operators/Source-or-Flow/interleave.md docs/src/main/paradox/stream/operators/Source-or-Flow/mapAsync.md docs/src/main/paradox/stream/operators/Source-or-Flow/fromMaterializer.md docs/src/main/paradox/stream/operators/Source-or-Flow/prefixAndTail.md docs/src/main/paradox/stream/operators/Source-or-Flow/intersperse.md docs/src/main/paradox/stream/operators/Source-or-Flow/collectType.md docs/src/main/paradox/stream/operators/Source-or-Flow/zipAll.md docs/src/main/paradox/stream/operators/Source-or-Flow/mergeAll.md docs/src/main/paradox/stream/operators/Source-or-Flow/orElse.md docs/src/main/paradox/stream/operators/Source-or-Flow/flatMapPrefix.md docs/src/main/paradox/stream/operators/Source-or-Flow/monitor.md docs/src/main/paradox/stream/operators/Source-or-Flow/concatLazy.md docs/src/main/paradox/stream/operators/Source-or-Flow/flatMapMerge.md docs/src/main/paradox/stream/operators/Source-or-Flow/mapError.md docs/src/main/paradox/stream/operators/Source-or-Flow/splitWhen.md docs/src/main/paradox/stream/operators/Source-or-Flow/concat.md docs/src/main/paradox/stream/operators/Source-or-Flow/extrapolate.md docs/src/main/paradox/stream/operators/Source-or-Flow/log.md docs/src/main/paradox/stream/operators/Source-or-Flow/reduce.md docs/src/main/paradox/stream/operators/Source-or-Flow/dropWithin.md docs/src/main/paradox/stream/operators/Source-or-Flow/zipLatestWith.md docs/src/main/paradox/stream/operators/Source-or-Flow/alsoTo.md docs/src/main/paradox/stream/operators/Source-or-Flow/initialTimeout.md docs/src/main/paradox/stream/operators/Source-or-Flow/merge.md docs/src/main/paradox/stream/operators/Source-or-Flow/mergeLatest.md docs/src/main/paradox/stream/operators/Source-or-Flow/sliding.md docs/src/main/paradox/stream/operators/Source-or-Flow/foldAsync.md docs/src/main/paradox/stream/operators/Source-or-Flow/collect.md docs/src/main/paradox/stream/operators/Source-or-Flow/divertTo.md docs/src/main/paradox/stream/operators/Source-or-Flow/limitWeighted.md docs/src/main/paradox/stream/operators/Source-or-Flow/mapConcat.md docs/src/main/paradox/stream/operators/Source-or-Flow/mergePrioritized.md docs/src/main/paradox/stream/operators/Source-or-Flow/detach.md docs/src/main/paradox/stream/operators/Source-or-Flow/takeWhile.md docs/src/main/paradox/stream/operators/Source-or-Flow/dropWhile.md docs/src/main/paradox/stream/operators/Source-or-Flow/groupedWithin.md docs/src/main/paradox/stream/operators/Source-or-Flow/groupedWeighted.md docs/src/main/paradox/stream/operators/Source-or-Flow/prependLazy.md docs/src/main/paradox/stream/operators/Source-or-Flow/interleaveAll.md docs/src/main/paradox/stream/operators/Source-or-Flow/limit.md docs/src/main/paradox/stream/operators/Source-or-Flow/mapAsyncUnordered.md docs/src/main/paradox/stream/operators/Source-or-Flow/concatAllLazy.md docs/src/main/paradox/stream/operators/Source-or-Flow/ask.md docs/src/main/paradox/stream/operators/Source-or-Flow/conflate.md docs/src/main/paradox/stream/operators/Source-or-Flow/mergeSorted.md docs/src/main/paradox/stream/operators/Source-or-Flow/aggregateWithBoundary.md docs/src/main/paradox/stream/operators/Source-or-Flow/backpressureTimeout.md docs/src/main/paradox/stream/operators/Source-or-Flow/recoverWithRetries.md docs/src/main/paradox/stream/operators/Source-or-Flow/statefulMap.md docs/src/main/paradox/stream/operators/Source-or-Flow/mergePreferred.md docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md docs/src/main/paradox/stream/operators/Source-or-Flow/conflateWithSeed.md docs/src/main/paradox/stream/operators/Source-or-Flow/recoverWith.md docs/src/main/paradox/stream/operators/Source-or-Flow/idleTimeout.md docs/src/main/paradox/stream/operators/Source-or-Flow/batch.md docs/src/main/paradox/stream/operators/Source-or-Flow/keepAlive.md docs/src/main/paradox/stream/operators/Source-or-Flow/filterNot.md docs/src/main/paradox/stream/operators/StreamConverters/fromInputStream.md docs/src/main/paradox/stream/operators/StreamConverters/asJavaStream.md docs/src/main/paradox/stream/operators/StreamConverters/javaCollectorParallelUnordered.md docs/src/main/paradox/stream/operators/StreamConverters/asInputStream.md docs/src/main/paradox/stream/operators/StreamConverters/javaCollector.md docs/src/main/paradox/stream/operators/StreamConverters/fromOutputStream.md docs/src/main/paradox/stream/operators/StreamConverters/asOutputStream.md docs/src/main/paradox/stream/operators/StreamConverters/fromJavaStream.md docs/src/main/paradox/stream/operators/ActorFlow/askWithStatus.md docs/src/main/paradox/stream/operators/ActorFlow/askWithContext.md docs/src/main/paradox/stream/operators/ActorFlow/askWithStatusAndContext.md docs/src/main/paradox/stream/operators/ActorFlow/ask.md docs/src/main/paradox/stream/operators/FileIO/toFile.md docs/src/main/paradox/stream/operators/FileIO/toPath.md docs/src/main/paradox/stream/operators/FileIO/fromPath.md docs/src/main/paradox/stream/operators/FileIO/fromFile.md docs/src/main/paradox/stream/operators/RestartSource/withBackoff.md docs/src/main/paradox/stream/operators/RestartSource/onFailuresWithBackoff.md docs/src/main/paradox/stream/operators/UnzipWith.md docs/src/main/paradox/stream/operators/Balance.md docs/src/main/paradox/stream/operators/RestartSink/withBackoff.md docs/src/main/paradox/stream/operators/Source/futureSource.md docs/src/main/paradox/stream/operators/Source/asSubscriber.md docs/src/main/paradox/stream/operators/Source/lazySource.md docs/src/main/paradox/stream/operators/Source/unfoldAsync.md docs/src/main/paradox/stream/operators/Source/tick.md docs/src/main/paradox/stream/operators/Source/lazyFuture.md docs/src/main/paradox/stream/operators/Source/actorRefWithBackpressure.md docs/src/main/paradox/stream/operators/Source/lazyFutureSource.md docs/src/main/paradox/stream/operators/Source/repeat.md docs/src/main/paradox/stream/operators/Source/lazilyAsync.md docs/src/main/paradox/stream/operators/Source/unfoldResource.md docs/src/main/paradox/stream/operators/Source/asSourceWithContext.md docs/src/main/paradox/stream/operators/Source/fromSourceCompletionStage.md docs/src/main/paradox/stream/operators/Source/from.md docs/src/main/paradox/stream/operators/Source/future.md docs/src/main/paradox/stream/operators/Source/failed.md docs/src/main/paradox/stream/operators/Source/fromFuture.md docs/src/main/paradox/stream/operators/Source/combine.md docs/src/main/paradox/stream/operators/Source/fromPublisher.md docs/src/main/paradox/stream/operators/Source/mergePrioritizedN.md docs/src/main/paradox/stream/operators/Source/zipWithN.md docs/src/main/paradox/stream/operators/Source/completionStage.md docs/src/main/paradox/stream/operators/Source/unfoldResourceAsync.md docs/src/main/paradox/stream/operators/Source/lazily.md docs/src/main/paradox/stream/operators/Source/actorRef.md docs/src/main/paradox/stream/operators/Source/fromIterator.md docs/src/main/paradox/stream/operators/Source/queue.md docs/src/main/paradox/stream/operators/Source/lazySingle.md docs/src/main/paradox/stream/operators/Source/fromCompletionStage.md docs/src/main/paradox/stream/operators/Source/lazyCompletionStageSource.md docs/src/main/paradox/stream/operators/Source/fromFutureSource.md docs/src/main/paradox/stream/operators/Source/cycle.md docs/src/main/paradox/stream/operators/Source/maybe.md docs/src/main/paradox/stream/operators/Source/fromJavaStream.md docs/src/main/paradox/stream/operators/Source/zipN.md docs/src/main/paradox/stream/operators/Source/unfold.md docs/src/main/paradox/stream/operators/Source/empty.md docs/src/main/paradox/stream/operators/Source/never.md docs/src/main/paradox/stream/operators/Source/lazyCompletionStage.md docs/src/main/paradox/stream/operators/Source/completionStageSource.md docs/src/main/paradox/stream/operators/Source/range.md docs/src/main/paradox/stream/operators/Source/single.md docs/src/main/paradox/stream/operators/Sink/head.md docs/src/main/paradox/stream/operators/Sink/cancelled.md docs/src/main/paradox/stream/operators/Sink/last.md docs/src/main/paradox/stream/operators/Sink/collection.md docs/src/main/paradox/stream/operators/Sink/lastOption.md docs/src/main/paradox/stream/operators/Sink/foreach.md docs/src/main/paradox/stream/operators/Sink/foreachParallel.md docs/src/main/paradox/stream/operators/Sink/actorRefWithBackpressure.md docs/src/main/paradox/stream/operators/Sink/setup.md docs/src/main/paradox/stream/operators/Sink/ignore.md docs/src/main/paradox/stream/operators/Sink/preMaterialize.md docs/src/main/paradox/stream/operators/Sink/lazyCompletionStageSink.md docs/src/main/paradox/stream/operators/Sink/asPublisher.md docs/src/main/paradox/stream/operators/Sink/seq.md docs/src/main/paradox/stream/operators/Sink/lazySink.md docs/src/main/paradox/stream/operators/Sink/fold.md docs/src/main/paradox/stream/operators/Sink/fromMaterializer.md docs/src/main/paradox/stream/operators/Sink/lazyInitAsync.md docs/src/main/paradox/stream/operators/Sink/takeLast.md docs/src/main/paradox/stream/operators/Sink/onComplete.md docs/src/main/paradox/stream/operators/Sink/combine.md docs/src/main/paradox/stream/operators/Sink/completionStageSink.md docs/src/main/paradox/stream/operators/Sink/reduce.md docs/src/main/paradox/stream/operators/Sink/futureSink.md docs/src/main/paradox/stream/operators/Sink/headOption.md docs/src/main/paradox/stream/operators/Sink/actorRef.md docs/src/main/paradox/stream/operators/Sink/queue.md docs/src/main/paradox/stream/operators/Sink/collect.md docs/src/main/paradox/stream/operators/Sink/lazyFutureSink.md docs/src/main/paradox/stream/operators/Sink/foreachAsync.md docs/src/main/paradox/stream/operators/Sink/fromSubscriber.md docs/src/main/paradox/stream/operators/Sink/never.md docs/src/main/paradox/stream/operators/Broadcast.md docs/src/main/paradox/stream/operators/RetryFlow/withBackoff.md docs/src/main/paradox/stream/operators/RetryFlow/withBackoffAndContext.md docs/src/main/paradox/stream/operators/Partition.md docs/src/main/paradox/stream/operators/index.md docs/src/main/paradox/stream/operators/Compression/gunzip.md docs/src/main/paradox/stream/operators/Compression/gzip.md docs/src/main/paradox/stream/operators/Compression/deflate.md docs/src/main/paradox/stream/operators/Compression/inflate.md docs/src/main/paradox/stream/operators/ActorSink/actorRefWithBackpressure.md docs/src/main/paradox/stream/operators/ActorSink/actorRef.md docs/src/main/paradox/stream/operators/PubSub/source.md docs/src/main/paradox/stream/operators/PubSub/sink.md docs/src/main/paradox/stream/operators/RestartFlow/withBackoff.md docs/src/main/paradox/stream/operators/RestartFlow/onFailuresWithBackoff.md docs/src/main/paradox/stream/operators/Unzip.md docs/src/main/paradox/stream/operators/ActorSource/actorRefWithBackpressure.md docs/src/main/paradox/stream/operators/ActorSource/actorRef.md docs/src/main/paradox/stream/operators/MergeSequence.md docs/src/main/paradox/stream/operators/Flow/fromSinkAndSourceCoupled.md docs/src/main/paradox/stream/operators/Flow/lazyFlow.md docs/src/main/paradox/stream/operators/Flow/lazyCompletionStageFlow.md docs/src/main/paradox/stream/operators/Flow/flattenOptional.md docs/src/main/paradox/stream/operators/Flow/lazyInitAsync.md docs/src/main/paradox/stream/operators/Flow/fromSinkAndSource.md docs/src/main/paradox/stream/operators/Flow/lazyFutureFlow.md docs/src/main/paradox/stream/operators/Flow/asFlowWithContext.md docs/src/main/paradox/stream/operators/Flow/futureFlow.md docs/src/main/paradox/stream/operators/Flow/completionStageFlow.md docs/src/main/paradox/stream/stream-composition.md docs/src/main/paradox/stream/stream-error.md docs/src/main/paradox/stream/stream-substream.md docs/src/main/paradox/stream/stream-flows-and-basics.md docs/src/main/paradox/stream/stream-introduction.md docs/src/main/paradox/stream/stream-testkit.md docs/src/main/paradox/stream/stream-cookbook.md docs/src/main/paradox/stream/stream-rate.md docs/src/main/paradox/stream/futures-interop.md docs/src/main/paradox/stream/reactive-streams-interop.md docs/src/main/paradox/stream/stream-refs.md docs/src/main/paradox/stream/stream-io.md docs/src/main/paradox/stream/index.md docs/src/main/paradox/stream/stream-dynamic.md docs/src/main/paradox/stream/actor-interop.md docs/src/main/paradox/stream/stream-context.md docs/src/main/paradox/stream/stream-graphs.md docs/src/main/paradox/index-network.md docs/src/main/paradox/discovery/index.md docs/src/main/paradox/multi-node-testing.md docs/src/main/paradox/includes/cluster.md docs/src/main/paradox/fault-tolerance.md docs/src/main/paradox/io-tcp.md docs/src/main/paradox/scheduler.md docs/src/main/paradox/testing.md docs/src/main/paradox/index-cluster.md docs/src/main/paradox/io-udp.md docs/src/main/paradox/release-notes/index.md docs/src/main/paradox/actors.md docs/src/main/paradox/serialization-jackson.md docs/src/main/paradox/fault-tolerance-sample.md docs/src/main/paradox/project/issue-tracking.md docs/src/main/paradox/project/examples.md docs/src/main/paradox/project/downstream-upgrade-strategy.md docs/src/main/paradox/project/migration-guides.md docs/src/main/paradox/project/licenses.md docs/src/main/paradox/project/index.md docs/src/main/paradox/project/immutable.md docs/src/main/paradox/project/scala3.md docs/src/main/paradox/project/links.md docs/src/main/paradox/project/rolling-update.md docs/src/main/paradox/persistence.md docs/src/main/paradox/common/may-change.md docs/src/main/paradox/common/binary-compatibility-rules.md docs/src/main/paradox/common/io-layer.md docs/src/main/paradox/common/other-modules.md docs/src/main/paradox/distributed-pub-sub.md docs/src/main/paradox/distributed-data.md docs/src/main/paradox/persistence-fsm.md docs/src/main/paradox/event-bus.md docs/src/main/paradox/index.md docs/src/main/paradox/logging.md docs/src/main/paradox/cluster-metrics.md docs/src/main/paradox/split-brain-resolver.md docs/src/main/paradox/typed/durable-state/persistence.md docs/src/main/paradox/typed/durable-state/persistence-style.md docs/src/main/paradox/typed/durable-state/cqrs.md docs/src/main/paradox/typed/guide/tutorial_5.md docs/src/main/paradox/typed/guide/tutorial_1.md docs/src/main/paradox/typed/guide/tutorial_4.md docs/src/main/paradox/typed/guide/diagrams/seq_chart_thread.svg docs/src/main/paradox/typed/guide/diagrams/object_graph_snakes.svg docs/src/main/paradox/typed/guide/diagrams/actor_graph.svg docs/src/main/paradox/typed/guide/diagrams/arch_tree_diagram.svg docs/src/main/paradox/typed/guide/diagrams/arch_boxes_diagram.svg docs/src/main/paradox/typed/guide/diagrams/exception_prop.svg docs/src/main/paradox/typed/guide/diagrams/device_manager_tree.svg docs/src/main/paradox/typed/guide/diagrams/object_graph.svg docs/src/main/paradox/typed/guide/diagrams/serialized_timeline_invariants.svg docs/src/main/paradox/typed/guide/diagrams/seq_chart.svg docs/src/main/paradox/typed/guide/diagrams/seq_chart_multi_thread.svg docs/src/main/paradox/typed/guide/actors-motivation.md docs/src/main/paradox/typed/guide/modules.md docs/src/main/paradox/typed/guide/introduction.md docs/src/main/paradox/typed/guide/actors-intro.md docs/src/main/paradox/typed/guide/tutorial.md docs/src/main/paradox/typed/guide/index.md docs/src/main/paradox/typed/guide/tutorial_3.md docs/src/main/paradox/typed/guide/tutorial_2.md docs/src/main/paradox/typed/cluster-dc.md docs/src/main/paradox/typed/testing-sync.md docs/src/main/paradox/typed/choosing-cluster.md docs/src/main/paradox/typed/cluster-sharding-concepts.md docs/src/main/paradox/typed/cluster-sharding.md docs/src/main/paradox/typed/reliable-delivery.md docs/src/main/paradox/typed/testing-async.md docs/src/main/paradox/typed/cluster.md docs/src/main/paradox/typed/replicated-eventsourcing-cart.md docs/src/main/paradox/typed/replicated-eventsourcing.md docs/src/main/paradox/typed/routers.md docs/src/main/paradox/typed/fsm.md docs/src/main/paradox/typed/extending.md docs/src/main/paradox/typed/fault-tolerance.md docs/src/main/paradox/typed/actor-discovery.md docs/src/main/paradox/typed/testing.md docs/src/main/paradox/typed/index-cluster.md docs/src/main/paradox/typed/cluster-membership.md docs/src/main/paradox/typed/actors.md docs/src/main/paradox/typed/cluster-sharded-daemon-process.md docs/src/main/paradox/typed/from-classic.md docs/src/main/paradox/typed/persistence.md docs/src/main/paradox/typed/distributed-pub-sub.md docs/src/main/paradox/typed/replicated-eventsourcing-auction.md docs/src/main/paradox/typed/distributed-data.md docs/src/main/paradox/typed/persistence-fsm.md docs/src/main/paradox/typed/index.md docs/src/main/paradox/typed/logging.md docs/src/main/paradox/typed/coexisting.md docs/src/main/paradox/typed/failure-detector.md docs/src/main/paradox/typed/persistence-style.md docs/src/main/paradox/typed/dispatchers.md docs/src/main/paradox/typed/stash.md docs/src/main/paradox/typed/interaction-patterns.md docs/src/main/paradox/typed/persistence-snapshot.md docs/src/main/paradox/typed/cluster-concepts.md docs/src/main/paradox/typed/persistence-testing.md docs/src/main/paradox/typed/style-guide.md docs/src/main/paradox/typed/index-persistence-durable-state.md docs/src/main/paradox/typed/cqrs.md docs/src/main/paradox/typed/cluster-singleton.md docs/src/main/paradox/typed/index-persistence.md docs/src/main/paradox/typed/actor-lifecycle.md docs/src/main/paradox/typed/mailboxes.md docs/src/main/paradox/typed/replicated-eventsourcing-examples.md docs/src/main/paradox/dispatchers.md docs/src/main/paradox/supervision-classic.md docs/src/main/paradox/persistence-query.md docs/src/main/paradox/additional/osgi.md docs/src/main/paradox/additional/operations.md docs/src/main/paradox/additional/rolling-updates.md docs/src/main/paradox/additional/packaging.md docs/src/main/paradox/additional/ide.md docs/src/main/paradox/additional/faq.md docs/src/main/paradox/additional/deploying.md docs/src/main/paradox/additional/deploy.md docs/src/main/paradox/additional/books.md docs/src/main/paradox/persistence-query-leveldb.md docs/src/main/paradox/futures.md docs/src/main/paradox/io-dns.md docs/src/main/paradox/cluster-usage.md docs/src/main/paradox/includes.md docs/src/main/paradox/assets/js/warnOldDocs.js docs/src/main/paradox/persistence-journals.md docs/src/main/paradox/cluster-client.md docs/src/main/paradox/index-utilities-classic.md docs/src/main/paradox/persistence-schema-evolution.md docs/src/main/paradox/cluster-singleton.md docs/src/main/paradox/io.md docs/src/main/paradox/mailboxes.md docs/src/main/paradox/multi-jvm-testing.md docs/src/main/categories/flow-operators-composed-of-sinks-and-sources.md docs/src/main/categories/time-aware-operators.md docs/src/main/categories/nesting-and-flattening-operators.md docs/src/main/categories/source-operators.md docs/src/main/categories/asynchronous-operators.md docs/src/main/categories/actor-interop-operators.md docs/src/main/categories/file-io-sinks-and-sources.md docs/src/main/categories/watching-status-operators.md docs/src/main/categories/backpressure-aware-operators.md docs/src/main/categories/fan-in-operators.md docs/src/main/categories/fan-out-operators.md docs/src/main/categories/error-handling.md docs/src/main/categories/sink-operators.md docs/src/main/categories/additional-sink-and-source-converters.md docs/src/main/categories/timer-driven-operators.md docs/src/main/categories/simple-operators.md docs/src/main/categories/compression-operators.md docs/src/main/protobuf/TwoPhaseSetMessages.proto docs/src/main/protobuf/FlightAppModels.proto actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/TailChopping.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/GracefulStopDocSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/InteractionPatternsSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/DispatchersDocSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/MailboxDocSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/AggregatorSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/coexistence/ClassicWatchingTypedSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/coexistence/TypedWatchingClassicSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/LoggingDocExamples.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/IntroSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/OOIntroSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/StashDocSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/myapp/package.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/extensions/ExtensionDocSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/FSMDocSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/SpawnProtocolDocSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/RouterSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/supervision/SupervisionCompileOnly.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/pubsub/PubSubExample.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/fromclassic/TypedSample.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/fromclassic/ClassicSample.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/Aggregator.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/FaultToleranceDocSpec.scala actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/StyleGuideDocExamples.scala persistence-typed-tests/src/test/scala/docs/org/apache/pekko/persistence/typed/ReplicatedAuctionExampleSpec.scala persistence-typed-tests/src/test/scala/docs/org/apache/pekko/persistence/typed/ReplicatedEventSourcingCompileOnlySpec.scala persistence-typed-tests/src/test/scala/docs/org/apache/pekko/persistence/typed/ReplicatedMovieWatchListExampleSpec.scala persistence-typed-tests/src/test/scala/docs/org/apache/pekko/persistence/typed/ReplicatedBlogExampleSpec.scala persistence-typed-tests/src/test/scala/docs/org/apache/pekko/persistence/typed/ReplicatedShoppingCartExampleSpec.scala persistence-typed/src/test/scala/docs/org/apache/pekko/persistence/typed/PersistentFsmToTypedMigrationSpec.scala persistence-typed/src/test/scala/docs/org/apache/pekko/persistence/typed/DurableStatePersistentBehaviorCompileOnly.scala persistence-typed/src/test/scala/docs/org/apache/pekko/persistence/typed/BlogPostEntityDurableState.scala persistence-typed/src/test/scala/docs/org/apache/pekko/persistence/typed/BlogPostEntity.scala persistence-typed/src/test/scala/docs/org/apache/pekko/persistence/typed/BasicPersistentBehaviorCompileOnly.scala persistence-typed/src/test/scala/docs/org/apache/pekko/persistence/typed/MovieWatchList.scala persistence-typed/src/test/scala/docs/org/apache/pekko/persistence/typed/StashingExample.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/AccountExampleWithEventHandlersInState.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/AccountExampleWithCommandHandlersInDurableState.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/DurableStateStoreQueryUsageCompileOnlySpec.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/ShardingCompileOnlySpec.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/AccountExampleSpec.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/AccountExampleWithCommandHandlersInState.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/AccountExampleDocSpec.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/ExternalShardAllocationCompileOnlySpec.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/ReplicatedShardingCompileOnlySpec.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/AccountExampleWithOptionDurableState.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/AccountExampleWithOptionState.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/HelloWorldPersistentEntityExample.scala cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/HelloWorldEventSourcedEntityExampleSpec.scala cluster-sharding-typed/src/test/scala/docs/delivery/ShardingDocExample.scala cluster-sharding-typed/src/test/scala/docs/delivery/PointToPointDocExample.scala cluster-sharding-typed/src/test/scala/docs/delivery/WorkPullingDocExample.scala stream-typed/src/test/java/docs/org/apache/pekko/stream/typed/ActorSinkExample.java stream-typed/src/test/java/docs/org/apache/pekko/stream/typed/ActorSourceWithBackpressureExample.java stream-typed/src/test/java/docs/org/apache/pekko/stream/typed/ActorSourceExample.java stream-typed/src/test/java/docs/org/apache/pekko/stream/typed/ActorSinkWithAckExample.java stream-typed/src/test/java/docs/javadsl/ActorFlowCompileTest.java stream-typed/src/test/scala/docs/org/apache/pekko/stream/typed/ActorSourceSinkExample.scala stream-typed/src/test/scala/docs/scaladsl/ActorFlowSpec.scala - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too long lines (1000+ characters) 29 files: stream-tests/src/test/scala/org/apache/pekko/stream/io/compression/CoderSpec.scala docs/src/main/paradox/images/tcp-message-protocol_establishing-outgoing.svg docs/src/main/paradox/images/graph_stage_detached_tracks_2.svg docs/src/main/paradox/images/tcp-message-protocol_receiving.svg docs/src/main/paradox/images/persistence-serializer-rename.svg docs/src/main/paradox/images/graph_stage_detached_tracks_1.svg docs/src/main/paradox/images/tcp-stream-run.svg docs/src/main/paradox/images/tcp-message-protocol_closing.svg docs/src/main/paradox/images/tcp-message-protocol_binding.svg docs/src/main/paradox/images/tcp-message-protocol_writing.svg docs/src/main/paradox/images/persistence-drop-event.svg docs/src/main/paradox/images/graph_stage_duplicate.svg docs/src/main/paradox/images/graph_stage_chain.svg docs/src/main/paradox/images/persistent-message-envelope.svg docs/src/main/paradox/images/persistence-drop-event-serializer.svg docs/src/main/paradox/images/persistence-event-adapter-1-n.svg docs/src/main/paradox/images/tcp-message-protocol_establishing-incoming.svg docs/src/main/paradox/images/tcp-message-protocol_noticing-close.svg docs/src/main/paradox/images/graph_stage_filter.svg docs/src/main/paradox/images/tcp-message-protocol_bind-connect-maxed-out.svg docs/src/main/paradox/images/persistence-detach-models.svg docs/src/main/paradox/images/tcp-message-protocol_unbinding.svg docs/src/main/paradox/images/tcp-stream-bind.svg docs/src/main/paradox/images/graph_stage_conceptual.svg docs/src/main/paradox/images/graph_stage_tracks_1.svg docs/src/main/paradox/images/graph_stage_map.svg docs/src/main/paradox/general/stream/stream-design.md docs/src/main/paradox/common/circuitbreaker.md actor/src/main/scala/org/apache/pekko/io/dns/internal/AsyncDnsResolver.scala - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Hidden files and folders path like ".*/[.][a-zA-Z0-9_]+.*" 25 files: .asf.yaml docs/src/main/paradox/.htaccess .gitignore .github/autolabeler.yml .github/workflows/scala3-compile.yml .github/workflows/nightly-builds.yml .github/workflows/format.yml .github/workflows/dependency-graph.yml .github/workflows/scala3-build.yml .github/workflows/nightly-builds-latest-jdks.yml .github/workflows/build-test-prValidation.yml .github/workflows/publish-1.0-nightly.yml .github/workflows/binary-compatibility-checks.yml .github/workflows/publish-1.0-docs.yml .github/workflows/timing-tests.yml .github/workflows/nightly-builds-aeron.yml .github/workflows/link-validator.yml .github/workflows/headers.yml .github/workflows/publish-nightly.yml .github/actions/sync-nightlies/action.yml .github/ISSUE_TEMPLATE/--question.md .github/ISSUE_TEMPLATE/---feature-request.md .github/ISSUE_TEMPLATE/---bug-report.md .gitattributes kubernetes/.gitignore - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Dependencies path like ".*/extern(al)?/.*" 8 files: cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/external/ExternalShardAllocationStrategySpec.scala cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/external/ClientTimeoutException.scala cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/external/internal/ExternalShardAllocationClientImpl.scala cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/external/scaladsl/ExternalShardAllocationClient.scala cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/external/javadsl/ExternalShardAllocationClient.scala cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/external/ExternalShardAllocationStrategy.scala cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/external/ShardLocations.scala cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/external/ExternalShardAllocation.scala - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too many lines (10000) 7 files: cluster/src/main/java/org/apache/pekko/cluster/protobuf/msg/ClusterMessages.java persistence-typed/src/main/java/org/apache/pekko/persistence/typed/serialization/ReplicatedEventSourcing.java distributed-data/src/main/java/org/apache/pekko/cluster/ddata/protobuf/msg/ReplicatedDataMessages.java distributed-data/src/main/java/org/apache/pekko/cluster/ddata/protobuf/msg/ReplicatorMessages.java cluster-sharding/src/main/java/org/apache/pekko/cluster/sharding/protobuf/msg/ClusterShardingMessages.java remote/src/main/java/org/apache/pekko/remote/ContainerFormats.java remote/src/main/java/org/apache/pekko/remote/WireFormats.java - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Sokrates conventions and configurations path like ".*/sokrates_.*?[.]json" 1 files: sokrates_conventions.json - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too long file (1000000+ bytes) 1 files: git-history.txt - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -