Package io.smallrye.reactive.messaging.helpers

Class BroadcastHelper

java.lang.Object

io.smallrye.reactive.messaging.helpers.BroadcastHelper

public class BroadcastHelper
extends Object

Method Summary

Modifier and Type	Method	Description
static org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	broadcastPublisher(org.reactivestreams.Publisher<? extends Message<?>> publisher, int numberOfSubscriberBeforeConnecting)	Wraps an existing Publisher for broadcasting.

Methods inherited from class java.lang.Object

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

Method Detail

broadcastPublisher

public static org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> broadcastPublisher(org.reactivestreams.Publisher<? extends Message<?>> publisher,
                                                                                                                            int numberOfSubscriberBeforeConnecting)

Wraps an existing Publisher for broadcasting.

Parameters:

publisher - The publisher to be wrapped

numberOfSubscriberBeforeConnecting - Number of subscribers that must be present before broadcast occurs. A value of 0 means any number of subscribers will trigger the broadcast.

Returns:

The wrapped Publisher in a new PublisherBuilder