Sinks.Many
that will broadcast signals to a single Subscriber
Sinks
through
variations under Sinks.many().unicast()
.root spec
for more advanced use cases such as building operators.Throwable
into a List
of Throwables.Disposable
on this container and dispose the previous
one (if any).Loggers
, even if SLF4J is available
on the classpath.logger factory
that will return loggers that not only use the
original logging framework used by reactor, but also use the logger set via LoggerUtils.enableCaptureWith(Logger)
, irrespective
of its name or how it was obtained.Logger
created through the provided Function
,
which takes a logger name as input.Loggers
, even if SLF4J is available
on the classpath.Loggers
, throwing an exception if
SLF4J isn't available on the classpath.Loggers
, even if SLF4J is available
on the classpath.Publisher
for each individual Subscriber
,
while streaming the values from a Publisher
derived from the same resource.Publisher
for each individual Subscriber
,
while streaming the values from a Publisher
derived from the same resource.Publisher
for each individual Subscriber
,
to derive a Mono
.Note that all steps of the operator chain that would need the
resource to be in an open stable state need to be described inside the resourceClosure
Function
.