Package | Description |
---|---|
reactor.core.reactivestreams |
Modifier and Type | Method and Description |
---|---|
static <I,O> org.reactivestreams.Publisher<O> |
PublisherFactory.intercept(org.reactivestreams.Publisher<? extends I> source,
Function<org.reactivestreams.Subscriber<? super O>,SubscriberBarrier<I,O>> barrierProvider)
Create a
Publisher intercepting all source signals with a SubscriberBarrier per Subscriber
provided by the given barrierProvider. |
Copyright © 2016. All rights reserved.