Method send

src/main/java/groovy/concurrent/BroadcastChannel.java:110–123

Sends a value to all current subscribers. @param value the value to broadcast @return an Awaitable that completes when all subscribers have accepted the value @throws ChannelClosedException if the broadcast channel is closed

(T value)

     * @throws ChannelClosedException if the broadcast channel is closed
     */
    public Awaitable<Void> send(T value) {
        Objects.requireNonNull(value, "value must not be null");
        if (closed) throw new ChannelClosedException("BroadcastChannel is closed");
        CompletableFuture<?>[] futures = subscribers.stream()
                .map(sub -> {
                    try {
                        return sub.send(value).toCompletableFuture();
                    } catch (ChannelClosedException e) {
                        return CompletableFuture.completedFuture(null);
                    }
                })
                .toArray(CompletableFuture[]::new);
        return GroovyPromise.of(CompletableFuture.allOf(futures));
    }

    /**
     * Closes this broadcast channel and all subscriber channels.