org.apache.pekko.http.impl.util

Class CollectorStage<T>

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.SinkShape<T>,Collect<T>>

org.apache.pekko.http.impl.util.CollectorStage<T>

All Implemented Interfaces:

org.apache.pekko.stream.Graph<org.apache.pekko.stream.SinkShape<T>,Collect<T>>

public class CollectorStage<T>
extends org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.SinkShape<T>,Collect<T>>

Stage similar to Sink.seq that provides a side-channel to get at the collection at any point. It will return all the collected elements and a flag whether the stream was completed or not.

When this is added to a fused flow it can be used to check what output and completion a given input will bring. Because the side-channel will go through the mailbox of the ActorGraphInterpreter the hope is that the fused stream will "run to exhaustion", i.e. it will run as far as it can, so that when the side-channel event is processed, no other (internal) events are still to be processed. This assumption does not hold if the source stream has asynchronous boundaries or components.

TODO: allow multiple rescheduling of AsyncCallback to make it more likely that all internal queues have been processed.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CollectorStage.Completed
class	CollectorStage.Completed$
class	CollectorStage.Initialized$
class	CollectorStage.Scheduled
class	CollectorStage.Scheduled$
static interface	CollectorStage.State State of the callback infrastructure
class	CollectorStage.Uninitialized$

Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph

org.apache.pekko.stream.Graph.GraphMapMatVal<S extends org.apache.pekko.stream.Shape,M>

Constructor Summary

Constructors

Constructor and Description
CollectorStage()

Method Summary

Modifier and Type	Method and Description
scala.Tuple2<org.apache.pekko.stream.stage.GraphStageLogic,Collect<T>>	createLogicAndMaterializedValue(org.apache.pekko.stream.Attributes inheritedAttributes)
org.apache.pekko.stream.Inlet<T>	in()
CollectorStage.Initialized$	Initialized() Accessor for nested Scala object
static <T,U> scala.concurrent.Future<scala.Tuple2<scala.collection.immutable.Seq<U>,java.lang.Object>>	resultAfterSourceElements(org.apache.pekko.stream.scaladsl.Source<T,java.lang.Object> source, org.apache.pekko.stream.scaladsl.Flow<T,U,java.lang.Object> flow, org.apache.pekko.stream.Materializer materializer)
org.apache.pekko.stream.SinkShape<T>	shape()
CollectorStage.Uninitialized$	Uninitialized() Accessor for nested Scala object

Methods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue

addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, initialAttributes, named, traversalBuilder, withAttributes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.pekko.stream.Graph

$init$, GraphMapMatVal, mapMaterializedValue

Constructor Detail

CollectorStage

public CollectorStage()

Method Detail

resultAfterSourceElements

public static <T,U> scala.concurrent.Future<scala.Tuple2<scala.collection.immutable.Seq<U>,java.lang.Object>> resultAfterSourceElements(org.apache.pekko.stream.scaladsl.Source<T,java.lang.Object> source,
                                                                                                                                        org.apache.pekko.stream.scaladsl.Flow<T,U,java.lang.Object> flow,
                                                                                                                                        org.apache.pekko.stream.Materializer materializer)

Uninitialized

public CollectorStage.Uninitialized$ Uninitialized()

Accessor for nested Scala object

Returns:

(undocumented)

Initialized

public CollectorStage.Initialized$ Initialized()

Accessor for nested Scala object

Returns:

(undocumented)

in

public org.apache.pekko.stream.Inlet<T> in()

shape

public org.apache.pekko.stream.SinkShape<T> shape()

createLogicAndMaterializedValue

public scala.Tuple2<org.apache.pekko.stream.stage.GraphStageLogic,Collect<T>> createLogicAndMaterializedValue(org.apache.pekko.stream.Attributes inheritedAttributes)

Specified by:

createLogicAndMaterializedValue in class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.SinkShape<T>,Collect<T>>