Package io.smallrye.reactive.messaging.providers.extension

Class EmitterImpl<T>

java.lang.Object

io.smallrye.reactive.messaging.providers.extension.AbstractEmitter<T>

io.smallrye.reactive.messaging.providers.extension.EmitterImpl<T>

Type Parameters:

T - the type of payload sent by the emitter.

All Implemented Interfaces:

io.smallrye.reactive.messaging.MessagePublisherProvider<T>, org.eclipse.microprofile.reactive.messaging.Emitter<T>

public class EmitterImpl<T>
extends AbstractEmitter<T>
implements org.eclipse.microprofile.reactive.messaging.Emitter<T>

Implementation of the emitter pattern.

Field Summary

Fields inherited from class io.smallrye.reactive.messaging.providers.extension.AbstractEmitter

internal, name, NO_SUBSCRIBER_EXCEPTION, publisher, synchronousFailure

Constructor Summary

Constructors

Constructor	Description
EmitterImpl(io.smallrye.reactive.messaging.EmitterConfiguration config, long defaultBufferSize)

Method Summary

Modifier and Type	Method	Description
<M extends org.eclipse.microprofile.reactive.messaging.Message<? extends T>> void	send(M msg)
CompletionStage<Void>	send(T payload)

Methods inherited from class io.smallrye.reactive.messaging.providers.extension.AbstractEmitter

complete, emit, error, getPublisher, hasRequests, isCancelled, verify

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.microprofile.reactive.messaging.Emitter

complete, error, hasRequests, isCancelled

Constructor Details

EmitterImpl

public EmitterImpl(io.smallrye.reactive.messaging.EmitterConfiguration config,
 long defaultBufferSize)

Method Details

send

public CompletionStage<Void> send(T payload)

Specified by:

send in interface org.eclipse.microprofile.reactive.messaging.Emitter<T>

send

public <M extends org.eclipse.microprofile.reactive.messaging.Message<? extends T>>
void send(M msg)

Specified by:

send in interface org.eclipse.microprofile.reactive.messaging.Emitter<T>