BroadcastHelper (SmallRye Reactive Messaging 3.13.0 API)

java.lang.Object
- io.smallrye.reactive.messaging.providers.helpers.BroadcastHelper

public class BroadcastHelper
extends Object

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static io.smallrye.mutiny.Multi<? extends Message<?>>`	`broadcastPublisher(io.smallrye.mutiny.Multi<? 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 io.smallrye.mutiny.Multi<? extends Message<?>> broadcastPublisher(io.smallrye.mutiny.Multi<? 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