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

Class MutinyEmitterImpl<T>

java.lang.Object

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

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

All Implemented Interfaces:

io.smallrye.reactive.messaging.EmitterType, io.smallrye.reactive.messaging.MessagePublisherProvider<T>, io.smallrye.reactive.messaging.MutinyEmitter<T>

public class MutinyEmitterImpl<T>
extends AbstractEmitter<T>
implements io.smallrye.reactive.messaging.MutinyEmitter<T>

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
MutinyEmitterImpl(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)
io.smallrye.mutiny.Uni<Void>	send(T payload)
void	sendAndAwait(T payload)
io.smallrye.mutiny.subscription.Cancellable	sendAndForget(T payload)
<M extends org.eclipse.microprofile.reactive.messaging.Message<? extends T>> io.smallrye.mutiny.Uni<Void>	sendMessage(M msg)
<M extends org.eclipse.microprofile.reactive.messaging.Message<? extends T>> void	sendMessageAndAwait(M msg)
<M extends org.eclipse.microprofile.reactive.messaging.Message<? extends T>> io.smallrye.mutiny.subscription.Cancellable	sendMessageAndForget(M msg)

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 io.smallrye.reactive.messaging.MutinyEmitter

complete, error, hasRequests, isCancelled

Constructor Details

MutinyEmitterImpl

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

Method Details

send

@CheckReturnValue
public io.smallrye.mutiny.Uni<Void> send(T payload)

Specified by:

send in interface io.smallrye.reactive.messaging.MutinyEmitter<T>

sendAndAwait

public void sendAndAwait(T payload)

Specified by:

sendAndAwait in interface io.smallrye.reactive.messaging.MutinyEmitter<T>

sendAndForget

public io.smallrye.mutiny.subscription.Cancellable sendAndForget(T payload)

Specified by:

sendAndForget in interface io.smallrye.reactive.messaging.MutinyEmitter<T>

send

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

Specified by:

send in interface io.smallrye.reactive.messaging.MutinyEmitter<T>

sendMessageAndForget

public <M extends org.eclipse.microprofile.reactive.messaging.Message<? extends T>>
io.smallrye.mutiny.subscription.Cancellable sendMessageAndForget(M msg)

Specified by:

sendMessageAndForget in interface io.smallrye.reactive.messaging.MutinyEmitter<T>

sendMessageAndAwait

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

Specified by:

sendMessageAndAwait in interface io.smallrye.reactive.messaging.MutinyEmitter<T>

sendMessage

@CheckReturnValue
public <M extends org.eclipse.microprofile.reactive.messaging.Message<? extends T>>
io.smallrye.mutiny.Uni<Void> sendMessage(M msg)

Specified by:

sendMessage in interface io.smallrye.reactive.messaging.MutinyEmitter<T>