Apache Pekko1.2.0-M1+7-96f70c4c-SNAPSHOT < Back

Packages

package root
Definition Classes
root
package org
Definition Classes
root
package apache
Definition Classes
org
package pekko
Definition Classes
apache
package stream
Definition Classes
pekko
package scaladsl
Scala API: The flow DSL allows the formulation of stream transformations based on some input.
Scala API: The flow DSL allows the formulation of stream transformations based on some input. The starting point is called Source and can be a collection, an iterator, a block of code which is evaluated repeatedly or a org.reactivestreams.Publisher. A flow with an attached input and open output is also a Source.
A flow may also be defined without an attached input or output and that is then a Flow. The Flow can be connected to the Source later by using Source#via with the flow as argument, and it remains a Source.
Transformations can be appended to Source and Flow with the operations defined in FlowOps. Each DSL element produces a new flow that can be further transformed, building up a description of the complete transformation pipeline.
The termination point of a flow is called Sink and can for example be a Future or org.reactivestreams.Subscriber. A flow with an attached output and open input is also a Sink.
If a flow has both an attached input and an attached output it becomes a RunnableGraph. In order to execute this pipeline the flow must be materialized by calling RunnableGraph#run on it.
You can create your Source, Flow and Sink in any order and then wire them together before they are materialized by connecting them using Flow#via and Flow#to, or connecting them into a GraphDSL with fan-in and fan-out elements.
See Reactive Streams for details on org.reactivestreams.Publisher and org.reactivestreams.Subscriber.
It should be noted that the streams modeled by this library are “hot”, meaning that they asynchronously flow through a series of processors without detailed control by the user. In particular it is not predictable how many elements a given transformation step might buffer before handing elements downstream, which means that transformation functions may be invoked more often than for corresponding transformations on strict collections like scala.collection.immutable.List. *An important consequence* is that elements that were produced into a stream may be discarded by later processors, e.g. when using the #take operator.
By default every operation is executed within its own org.apache.pekko.actor.Actor to enable full pipelining of the chained set of computations. This behavior is determined by the org.apache.pekko.stream.Materializer which is required by those methods that materialize the Flow into a series of org.reactivestreams.Processor instances. The returned reactive stream is fully started and active.
Definition Classes
stream
Balance
BidiFlow
Broadcast
BroadcastHub
Compression
Concat
CoupledTerminationFlow
DelayStrategy
FileIO
Flow
FlowOps
FlowOpsMat
FlowWithContext
FlowWithContextOps
Framing
GraphApply
GraphDSL
Interleave
JsonFraming
Keep
Merge
MergeHub
MergeLatest
MergePreferred
MergePrioritized
MergeSequence
MergeSorted
OrElse
Partition
PartitionHub
RestartFlow
RestartSink
RestartSource
RestartWithBackoffFlow
RetryFlow
RunnableGraph
ScalaSessionAPI
Sink
SinkQueue
SinkQueueWithCancel
SinkToCompletionStage
Source
SourceQueue
SourceQueueWithComplete
SourceToCompletionStage
SourceWithContext
StreamConverters
StreamRefs
SubFlow
TLS
TLSPlacebo
Tcp
TcpAttributes
TcpIdleTimeoutException
Unzip
UnzipWith
UnzipWith10
UnzipWith11
UnzipWith12
UnzipWith13
UnzipWith14
UnzipWith15
UnzipWith16
UnzipWith17
UnzipWith18
UnzipWith19
UnzipWith2
UnzipWith20
UnzipWith21
UnzipWith22
UnzipWith3
UnzipWith4
UnzipWith5
UnzipWith6
UnzipWith7
UnzipWith8
UnzipWith9
UnzipWithApply
WireTap
Zip
ZipLatest
ZipLatestWith
ZipLatestWith10
ZipLatestWith11
ZipLatestWith12
ZipLatestWith13
ZipLatestWith14
ZipLatestWith15
ZipLatestWith16
ZipLatestWith17
ZipLatestWith18
ZipLatestWith19
ZipLatestWith2
ZipLatestWith20
ZipLatestWith21
ZipLatestWith22
ZipLatestWith3
ZipLatestWith4
ZipLatestWith5
ZipLatestWith6
ZipLatestWith7
ZipLatestWith8
ZipLatestWith9
ZipLatestWithApply
ZipN
ZipWith
ZipWith10
ZipWith11
ZipWith12
ZipWith13
ZipWith14
ZipWith15
ZipWith16
ZipWith17
ZipWith18
ZipWith19
ZipWith2
ZipWith20
ZipWith21
ZipWith22
ZipWith3
ZipWith4
ZipWith5
ZipWith6
ZipWith7
ZipWith8
ZipWith9
ZipWithApply
ZipWithN

org.apache.pekko.stream.scaladsl

SourceQueueWithComplete

Companion trait SourceQueueWithComplete

object SourceQueueWithComplete

Source: Queue.scala

Linear Supertypes

AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

SourceQueueWithComplete
AnyRef
Any

Hide All
Show All

Visibility

Public
Protected

Type Members

implicit final class QueueOps[T] extends AnyVal

Value Members

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0
Definition Classes
Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@HotSpotIntrinsicCandidate() @native()
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@HotSpotIntrinsicCandidate() @native()
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@HotSpotIntrinsicCandidate() @native()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@HotSpotIntrinsicCandidate() @native()
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable]) @Deprecated
Deprecated
(Since version 9)

Packages

SourceQueueWithComplete

Companion trait SourceQueueWithComplete

object SourceQueueWithComplete

Type Members

Value Members

Deprecated Value Members

Inherited from AnyRef

Inherited from Any

Ungrouped

Packages

SourceQueueWithComplete

Companion trait SourceQueueWithComplete

object SourceQueueWithComplete

Type Members

Value Members

Deprecated Value Members

Inherited from AnyRef

Inherited from Any

Ungrouped

SourceQueueWithComplete