Top Description Inners Fields Constructors Methods

reactor.core.publisher

pack-priv final Class FluxOnAssembly<T>

Additional top-level class in compilation unit: AssemblyOp.

Class Inheritance

extends InternalFluxOperator<T, T>
implements Fuseable, AssemblyOp

java.lang.Object
reactor.core.publisher.Flux
reactor.core.publisher.FluxOperator
reactor.core.publisher.InternalFluxOperator
reactor.core.publisher.FluxOnAssembly

All Implemented Interfaces

reactor.core.publisher.AssemblyOp, reactor.core.Fuseable

Type Parameters

<T>: the value type passing through

Imports

java.io.Serializable, java.util.ArrayList, .Arrays, .HashMap, .LinkedHashMap, .LinkedHashSet, .LinkedList, .List, .Map, .Objects, .Set, java.util.function.Consumer, .Supplier, org.reactivestreams.Publisher, .Subscriber, .Subscription, reactor.core.CoreSubscriber, .Exceptions, .Fuseable, .Scannable, reactor.util.annotation.Nullable, reactor.util.function.Tuple3, .Tuples

Captures the current stacktrace when this publisher is created and makes it available/visible for debugging purposes from the inner Subscriber.

Note that getting a stacktrace is a costly operation.

The operator sanitizes the stacktrace and removes noisy entries such as:

java.lang.Thread entries
method references with source line of 1 (bridge methods)
Tomcat worker thread entries
JUnit setup

See Also: https://github.com/reactor/reactive-streams-commons

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FluxOnAssembly.AssemblySnapshot A snapshot of current assembly traceback, possibly with a user-readable description or a wider correlation ID.
pack-priv static class	FluxOnAssembly.CheckpointHeavySnapshot
pack-priv static class	FluxOnAssembly.CheckpointLightSnapshot
pack-priv static class	FluxOnAssembly.MethodReturnSnapshot
pack-priv static class	FluxOnAssembly.ObservedAtInformationNode
pack-priv static class	FluxOnAssembly.OnAssemblyConditionalSubscriber<T>
pack-priv static class	FluxOnAssembly.OnAssemblyException The holder for the assembly stacktrace (as its message).
pack-priv static class	FluxOnAssembly.OnAssemblySubscriber<T>

Field Summary

Modifier and Type	Field and Description
pack-priv final FluxOnAssembly.AssemblySnapshot	snapshotStack

Inherited from reactor.core.publisher.InternalFluxOperator:: optimizableOperator

Constructor Summary

Access	Constructor and Description
pack-priv	FluxOnAssembly(Flux<? extends T> source, FluxOnAssembly.AssemblySnapshot snapshotStack) Create an assembly trace decorated as a `Flux`.

Method Summary

Modifier and Type	Method and Description
pack-priv static void	fillStacktraceHeader(StringBuilder sb, Class<?> sourceClass, String description)
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Overrides reactor.core.publisher.InternalFluxOperator.scanUnsafe. Implements reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.
public String	stepName() Overrides default reactor.core.Scannable.stepName. Return a meaningful `String` representation of this `Scannable` in its chain of `parents()` and `actuals()`.
public CoreSubscriber<? super T>	subscribeOrReturn(CoreSubscriber<? super T> actual) Implements abstract reactor.core.publisher.InternalFluxOperator.subscribeOrReturn. Implements reactor.core.publisher.OptimizableOperator.subscribeOrReturn. Allow delegation of the subscription by returning a `CoreSubscriber`, or force subscription encapsulation by returning null.
public String	toString() Overrides reactor.core.publisher.Flux.toString. Returns a string representation of the object.
pack-priv static <T> CoreSubscriber<? super T>	wrapSubscriber(CoreSubscriber<? super T> actual, Flux<? extends T> source, Publisher<?> current, FluxOnAssembly.AssemblySnapshot snapshotStack)

Inherited from reactor.core.publisher.InternalFluxOperator:: nextOptimizableSource source subscribe