Uses of Interface
reactor.core.Scannable

Packages that use Scannable

Package	Description
reactor.core	Core components of the framework supporting extensions to the Reactive Stream programming model.
reactor.core.publisher	Provide main Reactive APIs in Flux and Mono, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.
reactor.test.subscriber	Components supporting the creation of test-oriented Subscribers.

Uses of Scannable in reactor.core

Fields in reactor.core with type parameters of type Scannable

Modifier and Type	Field and Description
static Scannable.Attr<Scannable>	Scannable.Attr.ACTUAL The direct dependent component downstream reference if any.
static Scannable.Attr<Scannable>	Scannable.Attr.PARENT Parent key exposes the direct upstream relationship of the scanned component.
static Scannable.Attr<Scannable>	Scannable.Attr.RUN_ON A key that links a Scannable to another Scannable it runs on.

Methods in reactor.core that return Scannable

Modifier and Type	Method and Description
static Scannable	Scannable.from(Object o) Attempt to cast the Object to a Scannable.

Methods in reactor.core that return types with arguments of type Scannable

Modifier and Type	Method and Description
default Stream<? extends Scannable>	Scannable.actuals() Return a Stream navigating the Subscriber chain (downward).
default Stream<? extends Scannable>	Scannable.inners() Return a Stream of referenced inners (flatmap, multicast etc)
default Stream<? extends Scannable>	Scannable.parents() Return a Stream navigating the Subscription chain (upward).

Uses of Scannable in reactor.core.publisher

Subinterfaces of Scannable in reactor.core.publisher

Modifier and Type	Interface and Description
static interface	Sinks.Empty<T> A base interface for standalone Sinks with complete-or-fail semantics.
static interface	Sinks.Many<T> A base interface for standalone Sinks with Flux semantics.
static interface	Sinks.ManyWithUpstream<T> A Sinks.Many which additionally allows being subscribed to an upstream Publisher, which is an advanced pattern requiring external synchronization.
static interface	Sinks.One<T> A base interface for standalone Sinks with Mono semantics.

Classes in reactor.core.publisher that implement Scannable

Modifier and Type	Class and Description
class	DirectProcessor<T> Deprecated. To be removed in 3.5, prefer clear cut usage of Sinks. Closest sink is Sinks.many().multicast().directBestEffort(), except it doesn't terminate overflowing downstreams.
class	EmitterProcessor<T> Deprecated. To be removed in 3.5. Prefer clear cut usage of Sinks through variations of Sinks.many().multicast().onBackpressureBuffer(). If you really need the subscribe-to-upstream functionality of a Processor, switch to Sinks.ManyWithUpstream with Sinks.unsafe() variants of Sinks.unsafe().manyWithUpstream(). This processor was blocking in EmitterProcessor.onNext(Object). This behaviour can be implemented with the Sinks API by calling Sinks.Many.tryEmitNext(Object) and retrying, e.g.: while (sink.tryEmitNext(v).hasFailed()) { LockSupport.parkNanos(10); }
class	FluxOperator<I,O> A decorating Flux Publisher that exposes Flux API over an arbitrary Publisher.
class	FluxProcessor<IN,OUT> Deprecated. Processors will be removed in 3.5. Prefer using Sinks.Many instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
class	MonoOperator<I,O> A decorating Mono Publisher that exposes Mono API over an arbitrary Publisher Useful to create operators which return a Mono.
class	MonoProcessor<O> Deprecated. Processors will be removed in 3.5. Prefer using Sinks.One or Sinks.Empty instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
static class	Operators.DeferredSubscription Base class for Subscribers that will receive their Subscriptions at any time, yet they might also need to be cancelled or requested at any time.
class	ReplayProcessor<T> Deprecated. To be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().replay().
class	UnicastProcessor<T> Deprecated. to be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().unicast().

Methods in reactor.core.publisher that return types with arguments of type Scannable

Modifier and Type	Method and Description
Stream<? extends Scannable>	ReplayProcessor.inners() Deprecated.
Stream<? extends Scannable>	DirectProcessor.inners() Deprecated.
Stream<Scannable>	UnicastProcessor.inners() Deprecated.
Stream<? extends Scannable>	EmitterProcessor.inners() Deprecated.
Stream<? extends Scannable>	FluxProcessor.inners() Deprecated.
Stream<? extends Scannable>	MonoProcessor.inners() Deprecated.

Method parameters in reactor.core.publisher with type arguments of type Scannable

Modifier and Type	Method and Description
static <I,O> Function<? super Publisher<I>,? extends Publisher<O>>	Operators.lift(BiFunction<Scannable,? super CoreSubscriber<? super O>,? extends CoreSubscriber<? super I>> lifter) Create a function that can be used to support a custom operator via CoreSubscriber decoration.
static <O> Function<? super Publisher<O>,? extends Publisher<O>>	Operators.lift(Predicate<Scannable> filter, BiFunction<Scannable,? super CoreSubscriber<? super O>,? extends CoreSubscriber<? super O>> lifter) Create a function that can be used to support a custom operator via CoreSubscriber decoration.
static <O> Function<? super Publisher<O>,? extends Publisher<O>>	Operators.lift(Predicate<Scannable> filter, BiFunction<Scannable,? super CoreSubscriber<? super O>,? extends CoreSubscriber<? super O>> lifter) Create a function that can be used to support a custom operator via CoreSubscriber decoration.

Uses of Scannable in reactor.test.subscriber

Subinterfaces of Scannable in reactor.test.subscriber

Modifier and Type	Interface and Description
interface	ConditionalTestSubscriber<T> Simple interface for a Fuseable.ConditionalSubscriber variant of the TestSubscriber.
interface	TestSubscriber<T> A CoreSubscriber that can be attached to any Publisher to later assert which events occurred at runtime.