reactor.core.publisher.ParallelFlux
Aliases
Parameters
null:
Null
subClasses
superClasses
java.lang.Object
org.reactivestreams.Publisher
reactor.core.CorePublisher
scala.lang.Any
Js Constructors
new reactor_core_publisher_ParallelFlux
( )
ApplyMethods
Methods
$bang$eq
(
x$1:
scala.lang.Any:
Any
,
)
:
java.lang.Boolean:
Boolean
$eq$eq
(
x$1:
scala.lang.Any:
Any
,
)
:
java.lang.Boolean:
Boolean
$hash$hash
()
:
java.lang.Int:
Int
as
(
x$1:
java.util.function.Function
[
null:
Null
scala.lang.Any:
Any
]
,
)
:
null:
Null
asInstanceOf
()
:
null:
Null
checkpoint
()
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
checkpoint
(
x$1:
java.lang.String:
String
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
checkpoint
(
x$1:
java.lang.String:
String
,
x$2:
java.lang.Boolean:
Boolean
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
collect
(
x$1:
java.util.function.Supplier
[
null:
Null
]
,
x$2:
java.util.function.BiConsumer
[
scala.lang.Any:
Any
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
collectSortedList
(
x$1:
java.util.Comparator
[
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.Mono
[
java.util.List
[
null:
Null
]
]
collectSortedList
(
x$1:
java.util.Comparator
[
scala.lang.Any:
Any
]
,
x$2:
java.lang.Int:
Int
,
)
:
reactor.core.publisher.Mono
[
java.util.List
[
null:
Null
]
]
concatMap
(
x$1:
java.util.function.Function
[
org.reactivestreams.Publisher
[
null:
Null
]
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
concatMap
(
x$1:
java.util.function.Function
[
org.reactivestreams.Publisher
[
null:
Null
]
scala.lang.Any:
Any
]
,
x$2:
java.lang.Int:
Int
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
concatMapDelayError
(
x$1:
java.util.function.Function
[
org.reactivestreams.Publisher
[
null:
Null
]
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
doAfterTerminate
(
x$1:
java.lang.Runnable
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
doOnCancel
(
x$1:
java.lang.Runnable
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
doOnComplete
(
x$1:
java.lang.Runnable
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
doOnEach
(
x$1:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
doOnError
(
x$1:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
doOnNext
(
x$1:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
doOnRequest
(
x$1:
java.util.function.LongConsumer
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
doOnSubscribe
(
x$1:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
doOnTerminate
(
x$1:
java.lang.Runnable
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
eq
(
x$1:
java.lang.Object:
Object
,
)
:
java.lang.Boolean:
Boolean
equals
(
x$1:
scala.lang.Any:
Any
,
)
:
java.lang.Boolean:
Boolean
filter
(
x$1:
java.util.function.Predicate
[
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
flatMap
(
x$1:
java.util.function.Function
[
org.reactivestreams.Publisher
[
null:
Null
]
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
flatMap
(
x$1:
java.util.function.Function
[
org.reactivestreams.Publisher
[
null:
Null
]
scala.lang.Any:
Any
]
,
x$2:
java.lang.Boolean:
Boolean
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
flatMap
(
x$1:
java.util.function.Function
[
org.reactivestreams.Publisher
[
null:
Null
]
scala.lang.Any:
Any
]
,
x$2:
java.lang.Boolean:
Boolean
,
x$3:
java.lang.Int:
Int
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
flatMap
(
x$1:
java.util.function.Function
[
org.reactivestreams.Publisher
[
null:
Null
]
scala.lang.Any:
Any
]
,
x$2:
java.lang.Boolean:
Boolean
,
x$3:
java.lang.Int:
Int
,
x$4:
java.lang.Int:
Int
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
getClass
()
:
java.lang.Class
[
scala.lang.Any:
Any
]
getPrefetch
()
:
java.lang.Int:
Int
groups
()
:
reactor.core.publisher.Flux
[
reactor.core.publisher.GroupedFlux
[
java.lang.Integer
null:
Null
]
]
hashCode
()
:
java.lang.Int:
Int
hide
()
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
isInstanceOf
()
:
java.lang.Boolean:
Boolean
log
()
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
log
(
x$1:
java.lang.String:
String
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
log
(
x$1:
java.lang.String:
String
,
x$2:
java.util.logging.Level
,
x$3:
Unknown:
Nothing
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
log
(
x$1:
java.lang.String:
String
,
x$2:
java.util.logging.Level
,
x$3:
java.lang.Boolean:
Boolean
,
x$4:
Unknown:
Nothing
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
map
(
x$1:
java.util.function.Function
[
null:
Null
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
name
(
x$1:
java.lang.String:
String
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
ne
(
x$1:
java.lang.Object:
Object
,
)
:
java.lang.Boolean:
Boolean
notify
()
:
scala.Unit:
Unit
notifyAll
()
:
scala.Unit:
Unit
ordered
(
x$1:
java.util.Comparator
[
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.Flux
[
null:
Null
]
ordered
(
x$1:
java.util.Comparator
[
scala.lang.Any:
Any
]
,
x$2:
java.lang.Int:
Int
,
)
:
reactor.core.publisher.Flux
[
null:
Null
]
parallelism
()
:
java.lang.Int:
Int
reduce
(
x$1:
java.util.function.BiFunction
[
null:
Null
null:
Null
null:
Null
]
,
)
:
reactor.core.publisher.Mono
[
null:
Null
]
reduce
(
x$1:
java.util.function.Supplier
[
null:
Null
]
,
x$2:
java.util.function.BiFunction
[
null:
Null
null:
Null
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
runOn
(
x$1:
reactor.core.scheduler.Scheduler
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
runOn
(
x$1:
reactor.core.scheduler.Scheduler
,
x$2:
java.lang.Int:
Int
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
sequential
()
:
reactor.core.publisher.Flux
[
null:
Null
]
sequential
(
x$1:
java.lang.Int:
Int
,
)
:
reactor.core.publisher.Flux
[
null:
Null
]
sorted
(
x$1:
java.util.Comparator
[
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.Flux
[
null:
Null
]
sorted
(
x$1:
java.util.Comparator
[
scala.lang.Any:
Any
]
,
x$2:
java.lang.Int:
Int
,
)
:
reactor.core.publisher.Flux
[
null:
Null
]
subscribe
()
:
reactor.core.Disposable
subscribe
(
x$1:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
)
:
reactor.core.Disposable
subscribe
(
x$1:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
x$2:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
)
:
reactor.core.Disposable
subscribe
(
x$1:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
x$2:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
x$3:
java.lang.Runnable
,
)
:
reactor.core.Disposable
subscribe
(
x$1:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
x$2:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
x$3:
java.lang.Runnable
,
x$4:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
)
:
reactor.core.Disposable
subscribe
(
x$1:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
x$2:
java.util.function.Consumer
[
scala.lang.Any:
Any
]
,
x$3:
java.lang.Runnable
,
x$4:
reactor.util.context.Context
,
)
:
reactor.core.Disposable
subscribe
(
x$1:
Array:
Array[Any]
,
)
:
scala.Unit:
Unit
subscribe
(
x$1:
org.reactivestreams.Subscriber
[
scala.lang.Any:
Any
]
,
)
:
scala.Unit:
Unit
subscribe
(
x$1:
reactor.core.CoreSubscriber
[
scala.lang.Any:
Any
]
,
)
:
scala.Unit:
Unit
synchronized
(
x$1:
null:
Null
,
)
:
null:
Null
tag
(
x$1:
java.lang.String:
String
,
x$2:
java.lang.String:
String
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
then
()
:
reactor.core.publisher.Mono
[
java.lang.Void
]
toString
()
:
java.lang.String:
String
transform
(
x$1:
java.util.function.Function
[
reactor.core.publisher.ParallelFlux
[
null:
Null
]
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
transformGroups
(
x$1:
java.util.function.Function
[
org.reactivestreams.Publisher
[
null:
Null
]
scala.lang.Any:
Any
]
,
)
:
reactor.core.publisher.ParallelFlux
[
null:
Null
]
wait
()
:
scala.Unit:
Unit
wait
(
x$1:
java.lang.Long:
Long
,
)
:
scala.Unit:
Unit
wait
(
x$1:
java.lang.Long:
Long
,
x$2:
java.lang.Int:
Int
,
)
:
scala.Unit:
Unit