Robuta

https://doc.akka.io/libraries/akka-core/current/stream/operators/Flow/fromSinkAndSource.html Flow.fromSinkAndSource • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreflow https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/mapError.html mapError • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coremaperror https://doc.akka.io/libraries/akka-core/current/stream/operators/Compression/inflate.html Compression.inflate • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corecompressioninflate https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/monitor.html monitor • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coremonitor https://doc.akka.io/libraries/akka-core/current/stream/operators/Source/never.html never • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corenever https://doc.akka.io/libraries/akka-core/current/stream/stream-dynamic.html Dynamic stream handling • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. dynamic stream handlingakka core https://doc.akka.io/libraries/akka-core/current/stream/operators/Flow/completionStageFlow.html Flow.completionStageFlow • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreflow https://doc.akka.io/libraries/akka-core/current/stream/stream-substream.html Substreams • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresubstreams https://doc.akka.io/libraries/akka-core/current/stream/operators/Source/lazyCompletionStageSource.html Source.lazyCompletionStageSource • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresource https://doc.akka.io/libraries/akka-core/current/stream/operators/RestartSink/withBackoff.html RestartSink.withBackoff • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/security/index.html Security Announcements • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. security announcementsakka core https://doc.akka.io/libraries/akka-core/current/stream/operators/Sink/never.html Sink.never • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresinknever https://doc.akka.io/libraries/akka-core/current/stream/operators/RetryFlow/withBackoffAndContext.html RetryFlow.withBackoffAndContext • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/stream/operators/StreamConverters/fromOutputStream.html StreamConverters.fromOutputStream • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/stream/operators/FileIO/toPath.html FileIO.toPath • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/stream/operators/ActorFlow/askWithContext.html ActorFlow.askWithContext • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/stream/operators/index.html Operators • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreoperators https://doc.akka.io/libraries/akka-core/current/stream/operators/Unzip.html Unzip • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreunzip https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/fold.html fold • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corefold https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/interleaveAll.html interleaveAll • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreinterleaveall https://doc.akka.io/libraries/akka-core/current/stream/stream-quickstart.html Streams Quickstart Guide • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. streams quickstart guideakka core https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/grouped.html grouped • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coregrouped https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/expand.html expand • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreexpand https://doc.akka.io/libraries/akka-core/current/stream/operators/Source/lazyFutureSource.html Source.lazyFutureSource • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresource https://doc.akka.io/libraries/akka-core/current/stream/stream-parallelism.html Pipelining and Parallelism • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. pipelining and parallelismakka core https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/collectType.html collectType • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corecollecttype https://doc.akka.io/libraries/akka-core/current/stream/operators/Sink/reduce.html Sink.reduce • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresinkreduce https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/takeWhile.html takeWhile • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coretakewhile https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/orElse.html orElse • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreorelse https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/collect.html collect • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corecollect https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/merge.html merge • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coremerge https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/extrapolate.html extrapolate • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreextrapolate https://doc.akka.io/libraries/akka-core/current/stream/operators/StreamConverters/fromJavaStream.html StreamConverters.fromJavaStream • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corefromjavastream https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/preMaterialize.html preMaterialize • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreprematerialize https://doc.akka.io/libraries/akka-core/current/stream/operators/Source/queue.html Source.queue • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresourcequeue https://doc.akka.io/libraries/akka-core/current/stream/operators/ActorSink/actorRef.html ActorSink.actorRef • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/stream/operators/Sink/setup.html Sink.setup • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresinksetup https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/zipWithIndex.html zipWithIndex • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corezipwithindex https://doc.akka.io/libraries/akka-core/current/stream/operators/Sink/lazySink.html Sink.lazySink • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresink https://doc.akka.io/libraries/akka-core/current/typed/index-cluster.html Cluster • Akka core Akka Cluster concepts, node membership service, CRDT Distributed Data, Cluster Singleton, Cluster Sharding, and Akka Cluster across multiple datacenters. akka corecluster https://doc.akka.io/libraries/akka-core/current/stream/operators/Source/zipN.html Source.zipN • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresource https://doc.akka.io/libraries/akka-core/current/stream/operators/Source/tick.html Source.tick • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresourcetick https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/foldAsync.html foldAsync • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corefoldasync https://doc.akka.io/libraries/akka-core/current/additional/deploying.html Deploying • Akka core How to deploy Akka Cluster to Kubernetes and Docker. akka coredeploying https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/concat.html concat • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreconcat https://doc.akka.io/libraries/akka-core/current/stream/operators/Sink/last.html Sink.last • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresinklast https://doc.akka.io/libraries/akka-core/current/stream/operators/Source/fromIterator.html Source.fromIterator • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresourcefromiterator https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/throttle.html throttle • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corethrottle https://doc.akka.io/libraries/akka-core/current/stream/operators/RestartSource/withBackoff.html RestartSource.withBackoff • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/stream/operators/Sink/combine.html Sink.combine • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresinkcombine https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/mapAsyncPartitioned.html mapAsyncPartitioned • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coremapasyncpartitioned https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/logWithMarker.html logWithMarker • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corelogwithmarker https://doc.akka.io/libraries/akka-core/current/stream/index.html Streams • Akka core An intuitive and safe way to do asynchronous, non-blocking backpressured stream processing. akka corestreams https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/filter.html filter • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corefilter https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/setup.html setup • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresetup https://doc.akka.io/libraries/akka-core/current/stream/operators/UnzipWith.html UnzipWith • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreunzipwith https://doc.akka.io/libraries/akka-core/current/stream/operators/StreamConverters/javaCollectorParallelUnordered.html StreamConverters.javaCollectorParallelUnordered • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/stream/stream-io.html Working with streaming IO • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. working with streaming ioakka core https://doc.akka.io/libraries/akka-core/current/stream/operators/Sink/fromMaterializer.html Sink.fromMaterializer • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresinkfrommaterializer https://doc.akka.io/libraries/akka-core/current/stream/operators/Source/fromFuture.html Source.fromFuture • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresource https://doc.akka.io/libraries/akka-core/current/stream/operators/Sink/ignore.html Sink.ignore • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresinkignore https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/alsoTo.html alsoTo • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corealsoto https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/watchTermination.html watchTermination • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corewatchtermination https://doc.akka.io/libraries/akka-core/current/stream/operators/Compression/gzip.html Compression.gzip • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corecompressiongzip https://doc.akka.io/libraries/akka-core/current/stream/operators/Flow/asFlowWithContext.html Flow.asFlowWithContext • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreflow https://doc.akka.io/libraries/akka-core/current/stream/operators/Flow/flattenOptional.html Flow.flattenOptional • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreflow https://doc.akka.io/libraries/akka-core/current/stream/operators/ActorSink/actorRefWithBackpressure.html ActorSink.actorRefWithBackpressure • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/stream/operators/StreamConverters/asInputStream.html StreamConverters.asInputStream • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/dropWhile.html dropWhile • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coredropwhile https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/conflate.html conflate • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreconflate https://doc.akka.io/libraries/akka-core/current/stream/operators/PubSub/source.html PubSub.source • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corepubsubsource https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/mergeLatest.html mergeLatest • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coremergelatest https://doc.akka.io/libraries/akka-core/current/stream/operators/ActorFlow/askWithStatusAndContext.html ActorFlow.askWithContext • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/index.html Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/stream/stream-context.html Context Propagation • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. context propagationakka core https://doc.akka.io/libraries/akka-core/current/stream/operators/Source/future.html Source.future • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresourcefuture https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/recoverWith.html recoverWith • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corerecoverwith https://doc.akka.io/libraries/akka-core/current/stream/operators/RestartFlow/withBackoff.html RestartFlow.withBackoff • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka core https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/aggregateWithBoundary.html aggregateWithBoundary • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreaggregatewithboundary https://doc.akka.io/libraries/akka-core/current/stream/operators/Source-or-Flow/initialDelay.html initialDelay • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coreinitialdelay https://doc.akka.io/libraries/akka-core/current/stream/operators/Compression/gunzip.html Compression.gunzip • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka corecompression https://doc.akka.io/libraries/akka-core/current/stream/operators/Sink/actorRefWithBackpressure.html Sink.actorRefWithBackpressure • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka coresink https://doc.akka.io/libraries/akka-core/current/index-classic.html Akka Classic • Akka core Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala. akka classiccore