Skip navigation links
Reactor Core
A B C D E F G H I J K L M N O P Q R S T U V W X Z 

N

name(String) - Method in class reactor.core.publisher.Flux
Give a name to this sequence, which can be retrieved using Scannable.name() as long as this is the first reachable Scannable.parents().
name(String) - Method in class reactor.core.publisher.Mono
Give a name to this sequence, which can be retrieved using Scannable.name() as long as this is the first reachable Scannable.parents().
name(String) - Method in class reactor.core.publisher.ParallelFlux
Give a name to this sequence, which can be retrieved using Scannable.name() as long as this is the first reachable Scannable.parents().
NAME - Static variable in class reactor.core.Scannable.Attr
An arbitrary name given to the operator component.
name() - Method in interface reactor.core.Scannable
Check this Scannable and its Scannable.parents() for a user-defined name and return the first one that is reachable, or default to this Scannable Scannable.stepName() if none.
never() - Static method in class reactor.core.Disposables
Return a new Disposable that can never be disposed.
never() - Static method in class reactor.core.publisher.Flux
Create a Flux that will never signal any data, error or completion signal.
never() - Static method in class reactor.core.publisher.Mono
Return a Mono that will never signal any data, error or completion signal, essentially running indefinitely.
newBoundedElastic(int, int, ThreadFactory, int) - Method in interface reactor.core.scheduler.Schedulers.Factory
Scheduler that dynamically creates a bounded number of ExecutorService-based Workers, reusing them once the Workers have been shut down.
newBoundedElastic(int, int, String) - Static method in class reactor.core.scheduler.Schedulers
Scheduler that dynamically creates a bounded number of ExecutorService-based Workers, reusing them once the Workers have been shut down.
newBoundedElastic(int, int, String, int) - Static method in class reactor.core.scheduler.Schedulers
Scheduler that dynamically creates a bounded number of ExecutorService-based Workers, reusing them once the Workers have been shut down.
newBoundedElastic(int, int, String, int, boolean) - Static method in class reactor.core.scheduler.Schedulers
Scheduler that dynamically creates a bounded number of ExecutorService-based Workers, reusing them once the Workers have been shut down.
newBoundedElastic(int, int, ThreadFactory, int) - Static method in class reactor.core.scheduler.Schedulers
Scheduler that dynamically creates a bounded number of ExecutorService-based Workers, reusing them once the Workers have been shut down.
newParallel(int, ThreadFactory) - Method in interface reactor.core.scheduler.Schedulers.Factory
Scheduler that hosts a fixed pool of workers and is suited for parallel work.
newParallel(String) - Static method in class reactor.core.scheduler.Schedulers
Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
newParallel(String, int) - Static method in class reactor.core.scheduler.Schedulers
Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
newParallel(String, int, boolean) - Static method in class reactor.core.scheduler.Schedulers
Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
newParallel(int, ThreadFactory) - Static method in class reactor.core.scheduler.Schedulers
Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
newSingle(ThreadFactory) - Method in interface reactor.core.scheduler.Schedulers.Factory
Scheduler that hosts a single worker and is suited for non-blocking work.
newSingle(String) - Static method in class reactor.core.scheduler.Schedulers
Scheduler that hosts a single-threaded ExecutorService-based worker.
newSingle(String, boolean) - Static method in class reactor.core.scheduler.Schedulers
Scheduler that hosts a single-threaded ExecutorService-based worker.
newSingle(ThreadFactory) - Static method in class reactor.core.scheduler.Schedulers
Scheduler that hosts a single-threaded ExecutorService-based worker.
next() - Method in class reactor.core.publisher.Flux
Emit only the first item emitted by this Flux, into a new Mono.
next(T) - Method in interface reactor.core.publisher.FluxSink
Emit a non-null element, generating an onNext signal.
next(T) - Static method in interface reactor.core.publisher.Signal
Creates and returns a Signal of variety Type.NEXT, which holds the value.
next(T, Context) - Static method in interface reactor.core.publisher.Signal
Creates and returns a Signal of variety Type.NEXT, which holds the value and the Context associated with the emitting source.
next(T) - Method in interface reactor.core.publisher.SynchronousSink
Try emitting, might throw an unchecked exception.
next(T) - Method in class reactor.test.publisher.TestPublisher
Send 1 onNext signal to the subscribers.
next(T, T...) - Method in class reactor.test.publisher.TestPublisher
Send 1-n onNext signals to the subscribers.
NonBlocking - Interface in reactor.core.scheduler
A marker interface that is detected on Threads while executing Reactor blocking APIs, resulting in these calls throwing an exception.
NONE - Static variable in interface reactor.core.Fuseable
Indicates the QueueSubscription can't support the requested mode.
NonNull - Annotation Type in reactor.util.annotation
A common Reactor annotation (similar to Spring ones) to declare that annotated elements cannot be null.
NonNullApi - Annotation Type in reactor.util.annotation
A common Reactor annotation (similar to Spring one) to declare that parameters and return values are to be considered as non-nullable by default for a given package.
NOT_SUPPORTED_MESSAGE - Static variable in interface reactor.core.Fuseable.QueueSubscription
 
now(TimeUnit) - Method in interface reactor.core.scheduler.Scheduler
Returns the "current time" notion of this scheduler.
now(TimeUnit) - Method in class reactor.test.scheduler.VirtualTimeScheduler
 
Nullable - Annotation Type in reactor.util.annotation
A common Reactor annotation (similar to Spring ones) to declare that annotated elements can be null under some circumstance.
nullOrNegativeRequestException(long) - Static method in class reactor.core.Exceptions
 
A B C D E F G H I J K L M N O P Q R S T U V W X Z 
Skip navigation links
Reactor Core