reactor.core.publisher.Flux

Aliases

Parameters

reactor.core.publisher.Signal[null:Null]

subClasses

reactor.core.publisher.GroupedFlux

superClasses

org.reactivestreams.Publisher
reactor.core.CorePublisher
scala.lang.Any

Js Constructors

new reactor_core_publisher_Flux(
)

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
all(x$1:java.util.function.Predicate[scala.lang.Any:Any], ):reactor.core.publisher.Mono[java.lang.Boolean]
any(x$1:java.util.function.Predicate[scala.lang.Any:Any], ):reactor.core.publisher.Mono[java.lang.Boolean]
as(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], ):null:Null
asInstanceOf():null:Null
blockFirst():null:Null
blockFirst(x$1:java.time.Duration, ):null:Null
blockLast():null:Null
blockLast(x$1:java.time.Duration, ):null:Null
buffer():reactor.core.publisher.Flux[java.util.List[null:Null]]
buffer(x$1:java.lang.Int:Int, ):reactor.core.publisher.Flux[java.util.List[null:Null]]
buffer(x$1:java.lang.Int:Int, x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[java.util.List[null:Null]]
buffer(x$1:java.lang.Int:Int, x$2:java.lang.Int:Int, x$3:java.util.function.Supplier[null:Null], ):reactor.core.publisher.Flux[null:Null]
buffer(x$1:java.lang.Int:Int, x$2:java.util.function.Supplier[null:Null], ):reactor.core.publisher.Flux[null:Null]
buffer(x$1:java.time.Duration, ):reactor.core.publisher.Flux[java.util.List[null:Null]]
buffer(x$1:java.time.Duration, x$2:java.time.Duration, ):reactor.core.publisher.Flux[java.util.List[null:Null]]
buffer(x$1:java.time.Duration, x$2:java.time.Duration, x$3:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[java.util.List[null:Null]]
buffer(x$1:java.time.Duration, x$2:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[java.util.List[null:Null]]
buffer(x$1:org.reactivestreams.Publisher[scala.lang.Any:Any], ):reactor.core.publisher.Flux[java.util.List[null:Null]]
buffer(x$1:org.reactivestreams.Publisher[scala.lang.Any:Any], x$2:java.util.function.Supplier[null:Null], ):reactor.core.publisher.Flux[null:Null]
bufferTimeout(x$1:java.lang.Int:Int, x$2:java.time.Duration, ):reactor.core.publisher.Flux[java.util.List[null:Null]]
bufferTimeout(x$1:java.lang.Int:Int, x$2:java.time.Duration, x$3:java.util.function.Supplier[null:Null], ):reactor.core.publisher.Flux[null:Null]
bufferTimeout(x$1:java.lang.Int:Int, x$2:java.time.Duration, x$3:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[java.util.List[null:Null]]
bufferTimeout(x$1:java.lang.Int:Int, x$2:java.time.Duration, x$3:reactor.core.scheduler.Scheduler, x$4:java.util.function.Supplier[null:Null], ):reactor.core.publisher.Flux[null:Null]
bufferUntil(x$1:java.util.function.Predicate[scala.lang.Any:Any], ):reactor.core.publisher.Flux[java.util.List[null:Null]]
bufferUntil(x$1:java.util.function.Predicate[scala.lang.Any:Any], x$2:java.lang.Boolean:Boolean, ):reactor.core.publisher.Flux[java.util.List[null:Null]]
bufferUntilChanged():reactor.core.publisher.Flux[java.util.List[null:Null]]
bufferUntilChanged(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], ):reactor.core.publisher.Flux[java.util.List[null:Null]]
bufferUntilChanged(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], x$2:java.util.function.BiPredicate[scala.lang.Any:Anyscala.lang.Any:Any], ):reactor.core.publisher.Flux[java.util.List[null:Null]]
bufferWhen(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[java.util.List[null:Null]]
bufferWhen(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$3:java.util.function.Supplier[null:Null], ):reactor.core.publisher.Flux[null:Null]
bufferWhile(x$1:java.util.function.Predicate[scala.lang.Any:Any], ):reactor.core.publisher.Flux[java.util.List[null:Null]]
cache():reactor.core.publisher.Flux[null:Null]
cache(x$1:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
cache(x$1:java.lang.Int:Int, x$2:java.time.Duration, ):reactor.core.publisher.Flux[null:Null]
cache(x$1:java.lang.Int:Int, x$2:java.time.Duration, x$3:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
cache(x$1:java.time.Duration, ):reactor.core.publisher.Flux[null:Null]
cache(x$1:java.time.Duration, x$2:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
cancelOn(x$1:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
cast(x$1:java.lang.Class[null:Null], ):reactor.core.publisher.Flux[null:Null]
checkpoint():reactor.core.publisher.Flux[null:Null]
checkpoint(x$1:java.lang.String:String, ):reactor.core.publisher.Flux[null:Null]
checkpoint(x$1:java.lang.String:String, x$2:java.lang.Boolean:Boolean, ):reactor.core.publisher.Flux[null:Null]
collect(x$1:java.util.function.Supplier[null:Null], x$2:java.util.function.BiConsumer[null:Nullscala.lang.Any:Any], ):reactor.core.publisher.Mono[null:Null]
collect(x$1:java.util.stream.Collector[null:Nullnull:Nullscala.lang.Any:Any], ):reactor.core.publisher.Mono[null:Null]
collectList():reactor.core.publisher.Mono[java.util.List[null:Null]]
collectMap(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], ):reactor.core.publisher.Mono[java.util.Map[null:Nullnull:Null]]
collectMap(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], x$2:java.util.function.Function[null:Nullscala.lang.Any:Any], ):reactor.core.publisher.Mono[java.util.Map[null:Nullnull:Null]]
collectMap(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], x$2:java.util.function.Function[null:Nullscala.lang.Any:Any], x$3:java.util.function.Supplier[java.util.Map[null:Nullnull:Null]], ):reactor.core.publisher.Mono[java.util.Map[null:Nullnull:Null]]
collectMultimap(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], ):reactor.core.publisher.Mono[java.util.Map[java.util.Collection[null:Null]null:Null]]
collectMultimap(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], x$2:java.util.function.Function[null:Nullscala.lang.Any:Any], ):reactor.core.publisher.Mono[java.util.Map[java.util.Collection[null:Null]null:Null]]
collectMultimap(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], x$2:java.util.function.Function[null:Nullscala.lang.Any:Any], x$3:java.util.function.Supplier[java.util.Map[java.util.Collection[null:Null]null:Null]], ):reactor.core.publisher.Mono[java.util.Map[java.util.Collection[null:Null]null:Null]]
collectSortedList():reactor.core.publisher.Mono[java.util.List[null:Null]]
collectSortedList(x$1:java.util.Comparator[scala.lang.Any:Any], ):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.Flux[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.Flux[null:Null]
concatMapDelayError(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
concatMapDelayError(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.Flux[null:Null]
concatMapDelayError(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
concatMapIterable(x$1:java.util.function.Function[java.lang.Iterable[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
concatMapIterable(x$1:java.util.function.Function[java.lang.Iterable[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
concatWith(x$1:org.reactivestreams.Publisher[null:Null], ):reactor.core.publisher.Flux[null:Null]
concatWithValues(x$1:Unknown:Nothing, ):reactor.core.publisher.Flux[null:Null]
contextWrite(x$1:java.util.function.Function[reactor.util.context.Contextreactor.util.context.Context], ):reactor.core.publisher.Flux[null:Null]
contextWrite(x$1:reactor.util.context.ContextView, ):reactor.core.publisher.Flux[null:Null]
count():reactor.core.publisher.Mono[java.lang.Long]
defaultIfEmpty(x$1:null:Null, ):reactor.core.publisher.Flux[null:Null]
delayElements(x$1:java.time.Duration, ):reactor.core.publisher.Flux[null:Null]
delayElements(x$1:java.time.Duration, x$2:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
delaySequence(x$1:java.time.Duration, ):reactor.core.publisher.Flux[null:Null]
delaySequence(x$1:java.time.Duration, x$2:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
delaySubscription(x$1:java.time.Duration, ):reactor.core.publisher.Flux[null:Null]
delaySubscription(x$1:java.time.Duration, x$2:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
delaySubscription(x$1:org.reactivestreams.Publisher[null:Null], ):reactor.core.publisher.Flux[null:Null]
delayUntil(x$1:java.util.function.Function[org.reactivestreams.Publisher[scala.lang.Any:Any]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
dematerialize():reactor.core.publisher.Flux[null:Null]
distinct():reactor.core.publisher.Flux[null:Null]
distinct(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
distinct(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], x$2:java.util.function.Supplier[null:Null], ):reactor.core.publisher.Flux[null:Null]
distinct(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], x$2:java.util.function.Supplier[null:Null], x$3:java.util.function.BiPredicate[null:Nullnull:Null], x$4:java.util.function.Consumer[null:Null], ):reactor.core.publisher.Flux[null:Null]
distinctUntilChanged():reactor.core.publisher.Flux[null:Null]
distinctUntilChanged(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
distinctUntilChanged(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], x$2:java.util.function.BiPredicate[scala.lang.Any:Anyscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
doAfterTerminate(x$1:java.lang.Runnable, ):reactor.core.publisher.Flux[null:Null]
doFinally(x$1:java.util.function.Consumer[reactor.core.publisher.SignalType], ):reactor.core.publisher.Flux[null:Null]
doFirst(x$1:java.lang.Runnable, ):reactor.core.publisher.Flux[null:Null]
doOnCancel(x$1:java.lang.Runnable, ):reactor.core.publisher.Flux[null:Null]
doOnComplete(x$1:java.lang.Runnable, ):reactor.core.publisher.Flux[null:Null]
doOnDiscard(x$1:java.lang.Class[null:Null], x$2:java.util.function.Consumer[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
doOnEach(x$1:java.util.function.Consumer[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
doOnError(x$1:java.lang.Class[null:Null], x$2:java.util.function.Consumer[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
doOnError(x$1:java.util.function.Consumer[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
doOnError(x$1:java.util.function.Predicate[scala.lang.Any:Any], x$2:java.util.function.Consumer[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
doOnNext(x$1:java.util.function.Consumer[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
doOnRequest(x$1:java.util.function.LongConsumer, ):reactor.core.publisher.Flux[null:Null]
doOnSubscribe(x$1:java.util.function.Consumer[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
doOnTerminate(x$1:java.lang.Runnable, ):reactor.core.publisher.Flux[null:Null]
elapsed():reactor.core.publisher.Flux[reactor.util.function.Tuple2[java.lang.Longnull:Null]]
elapsed(x$1:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[reactor.util.function.Tuple2[java.lang.Longnull:Null]]
elementAt(x$1:java.lang.Int:Int, ):reactor.core.publisher.Mono[null:Null]
elementAt(x$1:java.lang.Int:Int, x$2:null:Null, ):reactor.core.publisher.Mono[null:Null]
eq(x$1:java.lang.Object:Object, ):java.lang.Boolean:Boolean
equals(x$1:scala.lang.Any:Any, ):java.lang.Boolean:Boolean
expand(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
expand(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
expandDeep(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
expandDeep(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
filter(x$1:java.util.function.Predicate[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
filterWhen(x$1:java.util.function.Function[org.reactivestreams.Publisher[java.lang.Boolean]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
filterWhen(x$1:java.util.function.Function[org.reactivestreams.Publisher[java.lang.Boolean]scala.lang.Any:Any], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
flatMap(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
flatMap(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
flatMap(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, x$3:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
flatMap(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$3:java.util.function.Supplier[org.reactivestreams.Publisher[null:Null]], ):reactor.core.publisher.Flux[null:Null]
flatMapDelayError(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, x$3:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
flatMapIterable(x$1:java.util.function.Function[java.lang.Iterable[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
flatMapIterable(x$1:java.util.function.Function[java.lang.Iterable[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
flatMapSequential(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
flatMapSequential(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
flatMapSequential(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, x$3:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
flatMapSequentialDelayError(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, x$3:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
getClass():java.lang.Class[scala.lang.Any:Any]
getPrefetch():java.lang.Int:Int
groupBy(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], ):reactor.core.publisher.Flux[reactor.core.publisher.GroupedFlux[null:Nullnull:Null]]
groupBy(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[reactor.core.publisher.GroupedFlux[null:Nullnull:Null]]
groupBy(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], x$2:java.util.function.Function[null:Nullscala.lang.Any:Any], ):reactor.core.publisher.Flux[reactor.core.publisher.GroupedFlux[null:Nullnull:Null]]
groupBy(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], x$2:java.util.function.Function[null:Nullscala.lang.Any:Any], x$3:java.lang.Int:Int, ):reactor.core.publisher.Flux[reactor.core.publisher.GroupedFlux[null:Nullnull:Null]]
groupJoin(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$3:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$4:java.util.function.BiFunction[null:Nullscala.lang.Any:Anyscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
handle(x$1:java.util.function.BiConsumer[reactor.core.publisher.SynchronousSink[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
hasElement(x$1:null:Null, ):reactor.core.publisher.Mono[java.lang.Boolean]
hasElements():reactor.core.publisher.Mono[java.lang.Boolean]
hashCode():java.lang.Int:Int
hide():reactor.core.publisher.Flux[null:Null]
ignoreElements():reactor.core.publisher.Mono[null:Null]
index():reactor.core.publisher.Flux[reactor.util.function.Tuple2[java.lang.Longnull:Null]]
index(x$1:java.util.function.BiFunction[null:Nullscala.lang.Any:Anyscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
isInstanceOf():java.lang.Boolean:Boolean
join(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$3:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$4:java.util.function.BiFunction[null:Nullscala.lang.Any:Anyscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
last():reactor.core.publisher.Mono[null:Null]
last(x$1:null:Null, ):reactor.core.publisher.Mono[null:Null]
limitRate(x$1:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
limitRate(x$1:java.lang.Int:Int, x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
limitRequest(x$1:java.lang.Long:Long, ):reactor.core.publisher.Flux[null:Null]
log():reactor.core.publisher.Flux[null:Null]
log(x$1:java.lang.String:String, ):reactor.core.publisher.Flux[null:Null]
log(x$1:java.lang.String:String, x$2:java.util.logging.Level, x$3:Unknown:Nothing, ):reactor.core.publisher.Flux[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.Flux[null:Null]
log(x$1:reactor.util.Logger, ):reactor.core.publisher.Flux[null:Null]
log(x$1:reactor.util.Logger, x$2:java.util.logging.Level, x$3:java.lang.Boolean:Boolean, x$4:Unknown:Nothing, ):reactor.core.publisher.Flux[null:Null]
map(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
mapNotNull(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
materialize():reactor.core.publisher.Flux[reactor.core.publisher.Signal[null:Null]]
mergeComparingWith(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.util.Comparator[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
mergeOrderedWith(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.util.Comparator[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
mergeWith(x$1:org.reactivestreams.Publisher[null:Null], ):reactor.core.publisher.Flux[null:Null]
metrics():reactor.core.publisher.Flux[null:Null]
name(x$1:java.lang.String:String, ):reactor.core.publisher.Flux[null:Null]
ne(x$1:java.lang.Object:Object, ):java.lang.Boolean:Boolean
next():reactor.core.publisher.Mono[null:Null]
notify():scala.Unit:Unit
notifyAll():scala.Unit:Unit
ofType(x$1:java.lang.Class[null:Null], ):reactor.core.publisher.Flux[null:Null]
onBackpressureBuffer():reactor.core.publisher.Flux[null:Null]
onBackpressureBuffer(x$1:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
onBackpressureBuffer(x$1:java.lang.Int:Int, x$2:java.util.function.Consumer[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
onBackpressureBuffer(x$1:java.lang.Int:Int, x$2:java.util.function.Consumer[scala.lang.Any:Any], x$3:reactor.core.publisher.BufferOverflowStrategy, ):reactor.core.publisher.Flux[null:Null]
onBackpressureBuffer(x$1:java.lang.Int:Int, x$2:reactor.core.publisher.BufferOverflowStrategy, ):reactor.core.publisher.Flux[null:Null]
onBackpressureBuffer(x$1:java.time.Duration, x$2:java.lang.Int:Int, x$3:java.util.function.Consumer[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
onBackpressureBuffer(x$1:java.time.Duration, x$2:java.lang.Int:Int, x$3:java.util.function.Consumer[scala.lang.Any:Any], x$4:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
onBackpressureDrop():reactor.core.publisher.Flux[null:Null]
onBackpressureDrop(x$1:java.util.function.Consumer[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
onBackpressureError():reactor.core.publisher.Flux[null:Null]
onBackpressureLatest():reactor.core.publisher.Flux[null:Null]
onErrorComplete():reactor.core.publisher.Flux[null:Null]
onErrorComplete(x$1:java.lang.Class[java.lang.Throwable], ):reactor.core.publisher.Flux[null:Null]
onErrorComplete(x$1:java.util.function.Predicate[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
onErrorContinue(x$1:java.lang.Class[null:Null], x$2:java.util.function.BiConsumer[java.lang.Object:Objectjava.lang.Throwable], ):reactor.core.publisher.Flux[null:Null]
onErrorContinue(x$1:java.util.function.BiConsumer[java.lang.Object:Objectjava.lang.Throwable], ):reactor.core.publisher.Flux[null:Null]
onErrorContinue(x$1:java.util.function.Predicate[null:Null], x$2:java.util.function.BiConsumer[java.lang.Object:Objectjava.lang.Throwable], ):reactor.core.publisher.Flux[null:Null]
onErrorMap(x$1:java.lang.Class[null:Null], x$2:java.util.function.Function[java.lang.Throwablescala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
onErrorMap(x$1:java.util.function.Function[java.lang.Throwablescala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
onErrorMap(x$1:java.util.function.Predicate[scala.lang.Any:Any], x$2:java.util.function.Function[java.lang.Throwablescala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
onErrorResume(x$1:java.lang.Class[null:Null], x$2:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
onErrorResume(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
onErrorResume(x$1:java.util.function.Predicate[scala.lang.Any:Any], x$2:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
onErrorReturn(x$1:java.lang.Class[null:Null], x$2:null:Null, ):reactor.core.publisher.Flux[null:Null]
onErrorReturn(x$1:java.util.function.Predicate[scala.lang.Any:Any], x$2:null:Null, ):reactor.core.publisher.Flux[null:Null]
onErrorReturn(x$1:null:Null, ):reactor.core.publisher.Flux[null:Null]
onErrorStop():reactor.core.publisher.Flux[null:Null]
onTerminateDetach():reactor.core.publisher.Flux[null:Null]
or(x$1:org.reactivestreams.Publisher[null:Null], ):reactor.core.publisher.Flux[null:Null]
parallel():reactor.core.publisher.ParallelFlux[null:Null]
parallel(x$1:java.lang.Int:Int, ):reactor.core.publisher.ParallelFlux[null:Null]
parallel(x$1:java.lang.Int:Int, x$2:java.lang.Int:Int, ):reactor.core.publisher.ParallelFlux[null:Null]
publish():reactor.core.publisher.ConnectableFlux[null:Null]
publish(x$1:java.lang.Int:Int, ):reactor.core.publisher.ConnectableFlux[null:Null]
publish(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
publish(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
publishNext():reactor.core.publisher.Mono[null:Null]
publishOn(x$1:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
publishOn(x$1:reactor.core.scheduler.Scheduler, x$2:java.lang.Boolean:Boolean, x$3:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
publishOn(x$1:reactor.core.scheduler.Scheduler, x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
reduce(x$1:java.util.function.BiFunction[null:Nullnull:Nullnull:Null], ):reactor.core.publisher.Mono[null:Null]
reduce(x$1:null:Null, x$2:java.util.function.BiFunction[null:Nullnull:Nullscala.lang.Any:Any], ):reactor.core.publisher.Mono[null:Null]
reduceWith(x$1:java.util.function.Supplier[null:Null], x$2:java.util.function.BiFunction[null:Nullnull:Nullscala.lang.Any:Any], ):reactor.core.publisher.Mono[null:Null]
repeat():reactor.core.publisher.Flux[null:Null]
repeat(x$1:java.lang.Long:Long, ):reactor.core.publisher.Flux[null:Null]
repeat(x$1:java.lang.Long:Long, x$2:java.util.function.BooleanSupplier, ):reactor.core.publisher.Flux[null:Null]
repeat(x$1:java.util.function.BooleanSupplier, ):reactor.core.publisher.Flux[null:Null]
repeatWhen(x$1:java.util.function.Function[org.reactivestreams.Publisher[scala.lang.Any:Any]reactor.core.publisher.Flux[java.lang.Long]], ):reactor.core.publisher.Flux[null:Null]
replay():reactor.core.publisher.ConnectableFlux[null:Null]
replay(x$1:java.lang.Int:Int, ):reactor.core.publisher.ConnectableFlux[null:Null]
replay(x$1:java.lang.Int:Int, x$2:java.time.Duration, ):reactor.core.publisher.ConnectableFlux[null:Null]
replay(x$1:java.lang.Int:Int, x$2:java.time.Duration, x$3:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.ConnectableFlux[null:Null]
replay(x$1:java.time.Duration, ):reactor.core.publisher.ConnectableFlux[null:Null]
replay(x$1:java.time.Duration, x$2:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.ConnectableFlux[null:Null]
retry():reactor.core.publisher.Flux[null:Null]
retry(x$1:java.lang.Long:Long, ):reactor.core.publisher.Flux[null:Null]
retryWhen(x$1:reactor.util.retry.Retry, ):reactor.core.publisher.Flux[null:Null]
sample(x$1:java.time.Duration, ):reactor.core.publisher.Flux[null:Null]
sample(x$1:org.reactivestreams.Publisher[null:Null], ):reactor.core.publisher.Flux[null:Null]
sampleFirst(x$1:java.time.Duration, ):reactor.core.publisher.Flux[null:Null]
sampleFirst(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
sampleTimeout(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
sampleTimeout(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
scan(x$1:java.util.function.BiFunction[null:Nullnull:Nullnull:Null], ):reactor.core.publisher.Flux[null:Null]
scan(x$1:null:Null, x$2:java.util.function.BiFunction[null:Nullnull:Nullscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
scanWith(x$1:java.util.function.Supplier[null:Null], x$2:java.util.function.BiFunction[null:Nullnull:Nullscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
share():reactor.core.publisher.Flux[null:Null]
shareNext():reactor.core.publisher.Mono[null:Null]
single():reactor.core.publisher.Mono[null:Null]
single(x$1:null:Null, ):reactor.core.publisher.Mono[null:Null]
singleOrEmpty():reactor.core.publisher.Mono[null:Null]
skip(x$1:java.lang.Long:Long, ):reactor.core.publisher.Flux[null:Null]
skip(x$1:java.time.Duration, ):reactor.core.publisher.Flux[null:Null]
skip(x$1:java.time.Duration, x$2:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
skipLast(x$1:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
skipUntil(x$1:java.util.function.Predicate[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
skipUntilOther(x$1:org.reactivestreams.Publisher[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
skipWhile(x$1:java.util.function.Predicate[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
sort():reactor.core.publisher.Flux[null:Null]
sort(x$1:java.util.Comparator[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
startWith(x$1:Unknown:Nothing, ):reactor.core.publisher.Flux[null:Null]
startWith(x$1:java.lang.Iterable[null:Null], ):reactor.core.publisher.Flux[null:Null]
startWith(x$1:org.reactivestreams.Publisher[null:Null], ):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:org.reactivestreams.Subscriber[scala.lang.Any:Any], ):scala.Unit:Unit
subscribe(x$1:reactor.core.CoreSubscriber[scala.lang.Any:Any], ):scala.Unit:Unit
subscribeOn(x$1:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
subscribeOn(x$1:reactor.core.scheduler.Scheduler, x$2:java.lang.Boolean:Boolean, ):reactor.core.publisher.Flux[null:Null]
subscribeWith(x$1:null:Null, ):null:Null
subscriberContext(x$1:java.util.function.Function[reactor.util.context.Contextreactor.util.context.Context], ):reactor.core.publisher.Flux[null:Null]
subscriberContext(x$1:reactor.util.context.Context, ):reactor.core.publisher.Flux[null:Null]
switchIfEmpty(x$1:org.reactivestreams.Publisher[null:Null], ):reactor.core.publisher.Flux[null:Null]
switchMap(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
switchMap(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
switchOnFirst(x$1:java.util.function.BiFunction[org.reactivestreams.Publisher[null:Null]reactor.core.publisher.Flux[null:Null]reactor.core.publisher.Signal[null:Null]], ):reactor.core.publisher.Flux[null:Null]
switchOnFirst(x$1:java.util.function.BiFunction[org.reactivestreams.Publisher[null:Null]reactor.core.publisher.Flux[null:Null]reactor.core.publisher.Signal[null:Null]], x$2:java.lang.Boolean:Boolean, ):reactor.core.publisher.Flux[null:Null]
synchronized(x$1:null:Null, ):null:Null
tag(x$1:java.lang.String:String, x$2:java.lang.String:String, ):reactor.core.publisher.Flux[null:Null]
take(x$1:java.lang.Long:Long, ):reactor.core.publisher.Flux[null:Null]
take(x$1:java.lang.Long:Long, x$2:java.lang.Boolean:Boolean, ):reactor.core.publisher.Flux[null:Null]
take(x$1:java.time.Duration, ):reactor.core.publisher.Flux[null:Null]
take(x$1:java.time.Duration, x$2:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
takeLast(x$1:java.lang.Int:Int, ):reactor.core.publisher.Flux[null:Null]
takeUntil(x$1:java.util.function.Predicate[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
takeUntilOther(x$1:org.reactivestreams.Publisher[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
takeWhile(x$1:java.util.function.Predicate[scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
then():reactor.core.publisher.Mono[java.lang.Void]
then(x$1:reactor.core.publisher.Mono[null:Null], ):reactor.core.publisher.Mono[null:Null]
thenEmpty(x$1:org.reactivestreams.Publisher[java.lang.Void], ):reactor.core.publisher.Mono[java.lang.Void]
thenMany(x$1:org.reactivestreams.Publisher[null:Null], ):reactor.core.publisher.Flux[null:Null]
timed():reactor.core.publisher.Flux[reactor.core.publisher.Timed[null:Null]]
timed(x$1:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[reactor.core.publisher.Timed[null:Null]]
timeout(x$1:java.time.Duration, ):reactor.core.publisher.Flux[null:Null]
timeout(x$1:java.time.Duration, x$2:org.reactivestreams.Publisher[null:Null], ):reactor.core.publisher.Flux[null:Null]
timeout(x$1:java.time.Duration, x$2:org.reactivestreams.Publisher[null:Null], x$3:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
timeout(x$1:java.time.Duration, x$2:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[null:Null]
timeout(x$1:org.reactivestreams.Publisher[null:Null], ):reactor.core.publisher.Flux[null:Null]
timeout(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
timeout(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], x$3:org.reactivestreams.Publisher[null:Null], ):reactor.core.publisher.Flux[null:Null]
timestamp():reactor.core.publisher.Flux[reactor.util.function.Tuple2[java.lang.Longnull:Null]]
timestamp(x$1:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[reactor.util.function.Tuple2[java.lang.Longnull:Null]]
toIterable():java.lang.Iterable[null:Null]
toIterable(x$1:java.lang.Int:Int, ):java.lang.Iterable[null:Null]
toIterable(x$1:java.lang.Int:Int, x$2:java.util.function.Supplier[java.util.Queue[null:Null]], ):java.lang.Iterable[null:Null]
toStream():java.util.stream.Stream[null:Null]
toStream(x$1:java.lang.Int:Int, ):java.util.stream.Stream[null:Null]
toString():java.lang.String:String
transform(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
transformDeferred(x$1:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
transformDeferredContextual(x$1:java.util.function.BiFunction[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Anyscala.lang.Any:Any], ):reactor.core.publisher.Flux[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
window(x$1:java.lang.Int:Int, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
window(x$1:java.lang.Int:Int, x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
window(x$1:java.time.Duration, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
window(x$1:java.time.Duration, x$2:java.time.Duration, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
window(x$1:java.time.Duration, x$2:java.time.Duration, x$3:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
window(x$1:java.time.Duration, x$2:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
window(x$1:org.reactivestreams.Publisher[scala.lang.Any:Any], ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowTimeout(x$1:java.lang.Int:Int, x$2:java.time.Duration, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowTimeout(x$1:java.lang.Int:Int, x$2:java.time.Duration, x$3:java.lang.Boolean:Boolean, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowTimeout(x$1:java.lang.Int:Int, x$2:java.time.Duration, x$3:reactor.core.scheduler.Scheduler, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowTimeout(x$1:java.lang.Int:Int, x$2:java.time.Duration, x$3:reactor.core.scheduler.Scheduler, x$4:java.lang.Boolean:Boolean, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowUntil(x$1:java.util.function.Predicate[null:Null], ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowUntil(x$1:java.util.function.Predicate[null:Null], x$2:java.lang.Boolean:Boolean, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowUntil(x$1:java.util.function.Predicate[null:Null], x$2:java.lang.Boolean:Boolean, x$3:java.lang.Int:Int, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowUntilChanged():reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowUntilChanged(x$1:java.util.function.Function[scala.lang.Any:Anyscala.lang.Any:Any], ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowUntilChanged(x$1:java.util.function.Function[null:Nullscala.lang.Any:Any], x$2:java.util.function.BiPredicate[scala.lang.Any:Anyscala.lang.Any:Any], ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowWhen(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.util.function.Function[org.reactivestreams.Publisher[null:Null]scala.lang.Any:Any], ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowWhile(x$1:java.util.function.Predicate[null:Null], ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
windowWhile(x$1:java.util.function.Predicate[null:Null], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[reactor.core.publisher.Flux[null:Null]]
withLatestFrom(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.util.function.BiFunction[null:Nullscala.lang.Any:Anyscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
zipWith(x$1:org.reactivestreams.Publisher[null:Null], ):reactor.core.publisher.Flux[reactor.util.function.Tuple2[null:Nullnull:Null]]
zipWith(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.lang.Int:Int, ):reactor.core.publisher.Flux[reactor.util.function.Tuple2[null:Nullnull:Null]]
zipWith(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.lang.Int:Int, x$3:java.util.function.BiFunction[null:Nullscala.lang.Any:Anyscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
zipWith(x$1:org.reactivestreams.Publisher[null:Null], x$2:java.util.function.BiFunction[null:Nullscala.lang.Any:Anyscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]
zipWithIterable(x$1:java.lang.Iterable[null:Null], ):reactor.core.publisher.Flux[reactor.util.function.Tuple2[null:Nullnull:Null]]
zipWithIterable(x$1:java.lang.Iterable[null:Null], x$2:java.util.function.BiFunction[null:Nullscala.lang.Any:Anyscala.lang.Any:Any], ):reactor.core.publisher.Flux[null:Null]