Reactor Core 3.6.0 · reactor.core.publisher.SignalLogger

Field Summary

Modifier and Type	Field and Description
pack-priv static final int	AFTER_TERMINATE
pack-priv static final int	ALL
pack-priv static final int	CANCEL
pack-priv static final int	CONTEXT_PARENT
pack-priv final boolean	fuseable
pack-priv final long	id
pack-priv static final AtomicLong	IDS
pack-priv final Level	level
pack-priv final Logger	log
pack-priv static final String	LOG_TEMPLATE
pack-priv static final String	LOG_TEMPLATE_FUSEABLE
pack-priv static final int	ON_COMPLETE
pack-priv static final int	ON_ERROR
pack-priv static final int	ON_NEXT
pack-priv static final int	ON_SUBSCRIBE
pack-priv final String	operatorLine
pack-priv final int	options
pack-priv static final int	REQUEST
pack-priv final CorePublisher<IN>	source
pack-priv static final int	SUBSCRIBE

Constructor Summary

Access	Constructor and Description
pack-priv	SignalLogger(CorePublisher<IN> source, String category, Level level, boolean correlateStack, SignalType... options)
pack-priv	SignalLogger(CorePublisher<IN> source, String category, Level level, boolean correlateStack, Function<String, Logger> loggerSupplier, SignalType... options)

Method Summary

Modifier and Type	Method and Description
pack-priv void	log(SignalType the type of signal being logged signalType, Object the value for the signal (use empty string if not required) signalValue) Structured logging with level adaptation and operator ascii graph if required.
public Runnable	onAfterTerminateCall() Implements reactor.core.publisher.SignalPeek.onAfterTerminateCall. A task will run after termination via `Subscriber#onComplete()` or `Subscriber#onError(Throwable)`
public Runnable	onCancelCall() Implements reactor.core.publisher.SignalPeek.onCancelCall. A task that will run on `Subscription#cancel()`
public Runnable	onCompleteCall() Implements reactor.core.publisher.SignalPeek.onCompleteCall. A task that will run on `Subscriber#onComplete()`
public Consumer<? super Context>	onCurrentContextCall() Overrides default reactor.core.publisher.SignalPeek.onCurrentContextCall. A task that will run on `Context` read from downstream to upstream
public Consumer<? super Throwable>	onErrorCall() Implements reactor.core.publisher.SignalPeek.onErrorCall. A consumer that will observe `Subscriber#onError(Throwable)`}
public Consumer<? super IN>	onNextCall() Implements reactor.core.publisher.SignalPeek.onNextCall. A consumer that will observe `Subscriber#onNext(Object)`
public LongConsumer	onRequestCall() Implements reactor.core.publisher.SignalPeek.onRequestCall. A consumer of long that will observe `Subscription#request(long)`}
public Consumer<? super Subscription>	onSubscribeCall() Implements reactor.core.publisher.SignalPeek.onSubscribeCall. A consumer that will observe `Subscriber#onSubscribe(Subscription)`
pack-priv void	safeLog(SignalType signalType, Object signalValue) Structured logging with level adaptation and operator ascii graph if required + protection against loggers that detect objects like `Fuseable.QueueSubscription` as `java.util.Collection` and attempt to use their iterator for logging.
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Implements reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.
pack-priv static String	subscriptionAsString(Subscription s)
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

AFTER_TERMINATE	back to summary
pack-priv static final int AFTER_TERMINATE

ALL	back to summary
pack-priv static final int ALL

CANCEL	back to summary
pack-priv static final int CANCEL

CONTEXT_PARENT	back to summary
pack-priv static final int CONTEXT_PARENT

fuseable	back to summary
pack-priv final boolean fuseable

id	back to summary
pack-priv final long id

IDS	back to summary
pack-priv static final AtomicLong IDS

level	back to summary
pack-priv final Level level

log	back to summary
pack-priv final Logger log

LOG_TEMPLATE	back to summary
pack-priv static final String LOG_TEMPLATE

LOG_TEMPLATE_FUSEABLE	back to summary
pack-priv static final String LOG_TEMPLATE_FUSEABLE

ON_COMPLETE	back to summary
pack-priv static final int ON_COMPLETE

ON_ERROR	back to summary
pack-priv static final int ON_ERROR

ON_NEXT	back to summary
pack-priv static final int ON_NEXT

ON_SUBSCRIBE	back to summary
pack-priv static final int ON_SUBSCRIBE

operatorLine	back to summary
pack-priv final String operatorLine

options	back to summary
pack-priv final int options

REQUEST	back to summary
pack-priv static final int REQUEST

source	back to summary
pack-priv final CorePublisher<IN> source

SUBSCRIBE	back to summary
pack-priv static final int SUBSCRIBE

Constructor Detail

SignalLogger	back to summary
pack-priv SignalLogger(CorePublisher<IN> source, String category, Level level, boolean correlateStack, SignalType... options)

SignalLogger	back to summary
pack-priv SignalLogger(CorePublisher<IN> source, String category, Level level, boolean correlateStack, Function<String, Logger> loggerSupplier, SignalType... options)

Method Detail

log	back to summary
pack-priv void log(SignalType signalType, Object signalValue) Structured logging with level adaptation and operator ascii graph if required. Parameters signalType:SignalType the type of signal being logged signalValue:Object the value for the signal (use empty string if not required)

log

back to summary

pack-priv void log(SignalType signalType, Object signalValue)

Structured logging with level adaptation and operator ascii graph if required.

Parameters

signalType:SignalType: the type of signal being logged
signalValue:Object: the value for the signal (use empty string if not required)

onAfterTerminateCall back to summary

onAfterTerminateCall	back to summary
public Runnable onAfterTerminateCall() Implements reactor.core.publisher.SignalPeek.onAfterTerminateCall. Doc from reactor.core.publisher.SignalPeek.onAfterTerminateCall. A task will run after termination via `Subscriber#onComplete()` or `Subscriber#onError(Throwable)` Returns:Runnable A task will run after termination via `Subscriber#onComplete()` or `Subscriber#onError(Throwable)` Annotations @Override @Nullable

public Runnable onAfterTerminateCall()

Implements reactor.core.publisher.SignalPeek.onAfterTerminateCall.

Doc from reactor.core.publisher.SignalPeek.onAfterTerminateCall.

A task will run after termination via Subscriber#onComplete() or Subscriber#onError(Throwable)

Returns:Runnable

A task will run after termination via Subscriber#onComplete() or Subscriber#onError(Throwable)

Annotations

@Override
@Nullable

onCancelCall back to summary

onCancelCall	back to summary
public Runnable onCancelCall() Implements reactor.core.publisher.SignalPeek.onCancelCall. Doc from reactor.core.publisher.SignalPeek.onCancelCall. A task that will run on `Subscription#cancel()` Returns:Runnable A task that will run on `Subscription#cancel()` Annotations @Override @Nullable

public Runnable onCancelCall()

Implements reactor.core.publisher.SignalPeek.onCancelCall.

Doc from reactor.core.publisher.SignalPeek.onCancelCall.

A task that will run on Subscription#cancel()

Returns:Runnable

A task that will run on Subscription#cancel()

Annotations

@Override
@Nullable

onCompleteCall back to summary

onCompleteCall	back to summary
public Runnable onCompleteCall() Implements reactor.core.publisher.SignalPeek.onCompleteCall. Doc from reactor.core.publisher.SignalPeek.onCompleteCall. A task that will run on `Subscriber#onComplete()` Returns:Runnable A task that will run on `Subscriber#onComplete()` Annotations @Override @Nullable

public Runnable onCompleteCall()

Implements reactor.core.publisher.SignalPeek.onCompleteCall.

Doc from reactor.core.publisher.SignalPeek.onCompleteCall.

A task that will run on Subscriber#onComplete()

Returns:Runnable

A task that will run on Subscriber#onComplete()

Annotations

@Override
@Nullable

onCurrentContextCall back to summary

onCurrentContextCall	back to summary
public Consumer<? super Context> onCurrentContextCall() Overrides default reactor.core.publisher.SignalPeek.onCurrentContextCall. Doc from reactor.core.publisher.SignalPeek.onCurrentContextCall. A task that will run on `Context` read from downstream to upstream Returns:Consumer<? super Context> A task that will run on `Context` propagation from upstream to downstream Annotations @Nullable @Override

public Consumer<? super Context> onCurrentContextCall()

Overrides default reactor.core.publisher.SignalPeek.onCurrentContextCall.

Doc from reactor.core.publisher.SignalPeek.onCurrentContextCall.

A task that will run on Context read from downstream to upstream

Returns:Consumer<? super Context>

A task that will run on Context propagation from upstream to downstream

Annotations

@Nullable
@Override

onErrorCall back to summary

onErrorCall	back to summary
public Consumer<? super Throwable> onErrorCall() Implements reactor.core.publisher.SignalPeek.onErrorCall. Doc from reactor.core.publisher.SignalPeek.onErrorCall. A consumer that will observe `Subscriber#onError(Throwable)`} Returns:Consumer<? super Throwable> A consumer that will observe `Subscriber#onError(Throwable)` Annotations @Override @Nullable

public Consumer<? super Throwable> onErrorCall()

Implements reactor.core.publisher.SignalPeek.onErrorCall.

Doc from reactor.core.publisher.SignalPeek.onErrorCall.

A consumer that will observe Subscriber#onError(Throwable)}

Returns:Consumer<? super Throwable>

A consumer that will observe Subscriber#onError(Throwable)

Annotations

@Override
@Nullable

onNextCall back to summary

onNextCall	back to summary
public Consumer<? super IN> onNextCall() Implements reactor.core.publisher.SignalPeek.onNextCall. Doc from reactor.core.publisher.SignalPeek.onNextCall. A consumer that will observe `Subscriber#onNext(Object)` Returns:Consumer<? super IN> A consumer that will observe `Subscriber#onNext(Object)` Annotations @Override @Nullable

public Consumer<? super IN> onNextCall()

Implements reactor.core.publisher.SignalPeek.onNextCall.

Doc from reactor.core.publisher.SignalPeek.onNextCall.

A consumer that will observe Subscriber#onNext(Object)

Returns:Consumer<? super IN>

A consumer that will observe Subscriber#onNext(Object)

Annotations

@Override
@Nullable

onRequestCall back to summary

onRequestCall	back to summary
public LongConsumer onRequestCall() Implements reactor.core.publisher.SignalPeek.onRequestCall. Doc from reactor.core.publisher.SignalPeek.onRequestCall. A consumer of long that will observe `Subscription#request(long)`} Returns:LongConsumer A consumer of long that will observe `Subscription#request(long)`} Annotations @Override @Nullable

public LongConsumer onRequestCall()

Implements reactor.core.publisher.SignalPeek.onRequestCall.

Doc from reactor.core.publisher.SignalPeek.onRequestCall.

A consumer of long that will observe Subscription#request(long)}

Returns:LongConsumer

A consumer of long that will observe Subscription#request(long)}

Annotations

@Override
@Nullable

onSubscribeCall back to summary

onSubscribeCall	back to summary
public Consumer<? super Subscription> onSubscribeCall() Implements reactor.core.publisher.SignalPeek.onSubscribeCall. Doc from reactor.core.publisher.SignalPeek.onSubscribeCall. A consumer that will observe `Subscriber#onSubscribe(Subscription)` Returns:Consumer<? super Subscription> A consumer that will observe `Subscriber#onSubscribe(Subscription)` Annotations @Override @Nullable

public Consumer<? super Subscription> onSubscribeCall()

Implements reactor.core.publisher.SignalPeek.onSubscribeCall.

Doc from reactor.core.publisher.SignalPeek.onSubscribeCall.

A consumer that will observe Subscriber#onSubscribe(Subscription)

Returns:Consumer<? super Subscription>

A consumer that will observe Subscriber#onSubscribe(Subscription)

Annotations

@Override
@Nullable

safeLog back to summary

safeLog	back to summary
pack-priv void safeLog(SignalType signalType, Object signalValue) Structured logging with level adaptation and operator ascii graph if required + protection against loggers that detect objects like `Fuseable.QueueSubscription` as `java.util.Collection` and attempt to use their iterator for logging. See Also `log`

pack-priv void safeLog(SignalType signalType, Object signalValue)

Structured logging with level adaptation and operator ascii graph if required + protection against loggers that detect objects like Fuseable.QueueSubscription as java.util.Collection and attempt to use their iterator for logging.

See Also: log

scanUnsafe back to summary

scanUnsafe	back to summary
public Object scanUnsafe(Scannable.Attr<T> key) Implements reactor.core.Scannable.scanUnsafe. Doc from reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the `Attr` key, implementors should take care to return values of the correct type, and return null if no specific value is available. For public consumption of attributes, prefer using `scan(Attr)`, which will return a typed value and fall back to the key's default if the component didn't define any mapping. Parameters key:Scannable.Attr<T> a `Attr` to resolve for the component. Returns:Object the value associated to the key for that specific component, or null if none. Annotations @Override @Nullable

public Object scanUnsafe(Scannable.Attr<T> key)

Implements reactor.core.Scannable.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the Attr key, implementors should take care to return values of the correct type, and return null if no specific value is available.

For public consumption of attributes, prefer using scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters

key:Scannable.Attr<T>: a Attr to resolve for the component.

Returns:Object

the value associated to the key for that specific component, or null if none.

Annotations

@Override
@Nullable

subscriptionAsString	back to summary
pack-priv static String subscriptionAsString(Subscription s)

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Returns:String a string representation of the object. Annotations @Override

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

pack-priv final Class SignalLogger<IN>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail