Package akka.stream.impl
Class Stages.DefaultAttributes$
- java.lang.Object
-
- akka.stream.impl.Stages.DefaultAttributes$
-
- Enclosing class:
- Stages
public static class Stages.DefaultAttributes$ extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static Stages.DefaultAttributes$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description DefaultAttributes$()
-
Method Summary
-
-
-
Field Detail
-
MODULE$
public static final Stages.DefaultAttributes$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
IODispatcher
public ActorAttributes.Dispatcher IODispatcher()
-
inputBufferOne
public Attributes inputBufferOne()
-
fused
public Attributes fused()
-
materializedValueSource
public Attributes materializedValueSource()
-
map
public Attributes map()
-
log
public Attributes log()
-
filter
public Attributes filter()
-
filterNot
public Attributes filterNot()
-
collect
public Attributes collect()
-
recover
public Attributes recover()
-
mapAsync
public Attributes mapAsync()
-
mapAsyncUnordered
public Attributes mapAsyncUnordered()
-
ask
public Attributes ask()
-
grouped
public Attributes grouped()
-
groupedWithin
public Attributes groupedWithin()
-
groupedWeightedWithin
public Attributes groupedWeightedWithin()
-
limit
public Attributes limit()
-
limitWeighted
public Attributes limitWeighted()
-
sliding
public Attributes sliding()
-
take
public Attributes take()
-
drop
public Attributes drop()
-
takeWhile
public Attributes takeWhile()
-
dropWhile
public Attributes dropWhile()
-
scan
public Attributes scan()
-
scanAsync
public Attributes scanAsync()
-
fold
public Attributes fold()
-
foldAsync
public Attributes foldAsync()
-
reduce
public Attributes reduce()
-
intersperse
public Attributes intersperse()
-
buffer
public Attributes buffer()
-
conflate
public Attributes conflate()
-
batch
public Attributes batch()
-
batchWeighted
public Attributes batchWeighted()
-
expand
public Attributes expand()
-
statefulMapConcat
public Attributes statefulMapConcat()
-
detacher
public Attributes detacher()
-
groupBy
public Attributes groupBy()
-
prefixAndTail
public Attributes prefixAndTail()
-
split
public Attributes split()
-
concatAll
public Attributes concatAll()
-
processor
public Attributes processor()
-
processorWithKey
public Attributes processorWithKey()
-
identityOp
public Attributes identityOp()
-
delimiterFraming
public Attributes delimiterFraming()
-
initial
public Attributes initial()
-
completion
public Attributes completion()
-
idle
public Attributes idle()
-
idleTimeoutBidi
public Attributes idleTimeoutBidi()
-
delayInitial
public Attributes delayInitial()
-
idleInject
public Attributes idleInject()
-
backpressureTimeout
public Attributes backpressureTimeout()
-
merge
public Attributes merge()
-
mergePreferred
public Attributes mergePreferred()
-
mergePrioritized
public Attributes mergePrioritized()
-
flattenMerge
public Attributes flattenMerge()
-
recoverWith
public Attributes recoverWith()
-
broadcast
public Attributes broadcast()
-
wireTap
public Attributes wireTap()
-
balance
public Attributes balance()
-
zip
public Attributes zip()
-
zipLatest
public Attributes zipLatest()
-
zipN
public Attributes zipN()
-
zipWithN
public Attributes zipWithN()
-
zipWithIndex
public Attributes zipWithIndex()
-
unzip
public Attributes unzip()
-
concat
public Attributes concat()
-
orElse
public Attributes orElse()
-
repeat
public Attributes repeat()
-
unfold
public Attributes unfold()
-
unfoldAsync
public Attributes unfoldAsync()
-
delay
public Attributes delay()
-
terminationWatcher
public Attributes terminationWatcher()
-
watch
public Attributes watch()
-
publisherSource
public Attributes publisherSource()
-
iterableSource
public Attributes iterableSource()
-
cycledSource
public Attributes cycledSource()
-
futureSource
public Attributes futureSource()
-
futureFlattenSource
public Attributes futureFlattenSource()
-
tickSource
public Attributes tickSource()
-
singleSource
public Attributes singleSource()
-
emptySource
public Attributes emptySource()
-
maybeSource
public Attributes maybeSource()
-
failedSource
public Attributes failedSource()
-
concatSource
public Attributes concatSource()
-
concatMatSource
public Attributes concatMatSource()
-
subscriberSource
public Attributes subscriberSource()
-
actorPublisherSource
public Attributes actorPublisherSource()
-
actorRefSource
public Attributes actorRefSource()
-
actorRefWithAckSource
public Attributes actorRefWithAckSource()
-
queueSource
public Attributes queueSource()
-
inputStreamSource
public Attributes inputStreamSource()
-
outputStreamSource
public Attributes outputStreamSource()
-
fileSource
public Attributes fileSource()
-
unfoldResourceSource
public Attributes unfoldResourceSource()
-
unfoldResourceSourceAsync
public Attributes unfoldResourceSourceAsync()
-
asJavaStream
public Attributes asJavaStream()
-
javaCollectorParallelUnordered
public Attributes javaCollectorParallelUnordered()
-
javaCollector
public Attributes javaCollector()
-
subscriberSink
public Attributes subscriberSink()
-
cancelledSink
public Attributes cancelledSink()
-
headSink
public Attributes headSink()
-
headOptionSink
public Attributes headOptionSink()
-
lastSink
public Attributes lastSink()
-
lastOptionSink
public Attributes lastOptionSink()
-
takeLastSink
public Attributes takeLastSink()
-
seqSink
public Attributes seqSink()
-
publisherSink
public Attributes publisherSink()
-
fanoutPublisherSink
public Attributes fanoutPublisherSink()
-
ignoreSink
public Attributes ignoreSink()
-
actorRefSink
public Attributes actorRefSink()
-
actorRefWithAck
public Attributes actorRefWithAck()
-
actorSubscriberSink
public Attributes actorSubscriberSink()
-
queueSink
public Attributes queueSink()
-
lazySink
public Attributes lazySink()
-
lazyFlow
public Attributes lazyFlow()
-
lazySource
public Attributes lazySource()
-
outputStreamSink
public Attributes outputStreamSink()
-
inputStreamSink
public Attributes inputStreamSink()
-
fileSink
public Attributes fileSink()
-
fromJavaStream
public Attributes fromJavaStream()
-
inputBoundary
public Attributes inputBoundary()
-
outputBoundary
public Attributes outputBoundary()
-
-