Package io.micronaut.core.async.propagation

Class ReactivePropagation

java.lang.Object

io.micronaut.core.async.propagation.ReactivePropagation

public final class ReactivePropagation
extends Object

Reactive propagation of PropagatedContext.

Since:

4.0.0

Author:

Denis Stepanov

Method Summary

Modifier and Type	Method	Description
static <T> Publisher<T>	propagate(PropagatedContext propagatedContext, Publisher<T> actual)	Creates propagation context aware Publisher.
static <T> Subscriber<T>	propagate(PropagatedContext propagatedContext, Subscriber<T> actual)	Creates propagation context aware Subscriber.
static <T> Publisher<T>	propagate(PropagatedContext propagatedContext, reactor.core.CorePublisher<T> actual)	Creates propagation context aware Publisher.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

propagate

public static <T> Publisher<T> propagate(PropagatedContext propagatedContext,
 Publisher<T> actual)

Creates propagation context aware Publisher.

Type Parameters:

T - The publisher element type

Parameters:

propagatedContext - The context

actual - The publisher

Returns:

propagation aware publisher

propagate

public static <T> Publisher<T> propagate(PropagatedContext propagatedContext,
 reactor.core.CorePublisher<T> actual)

Creates propagation context aware Publisher.

Type Parameters:

T - The publisher element type

Parameters:

propagatedContext - The context

actual - The publisher

Returns:

propagation aware publisher

Since:

4.8

propagate

public static <T> Subscriber<T> propagate(PropagatedContext propagatedContext,
 Subscriber<T> actual)

Creates propagation context aware Subscriber.

Type Parameters:

T - The subscriber element type

Parameters:

propagatedContext - The context

actual - The subscriber

Returns:

propagation aware subscriber