Package io.smallrye.reactive.messaging.extension

Class AbstractEmitter<T>

java.lang.Object

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

All Implemented Interfaces:

EmitterBehavior

Direct Known Subclasses:

EmitterImpl, MutinyEmitterImpl

public abstract class AbstractEmitter<T>
extends Object
implements EmitterBehavior

Field Summary

Fields

Modifier and Type	Field	Description
protected AtomicReference<io.smallrye.mutiny.subscription.MultiEmitter<? super Message<? extends T>>>	internal
protected String	name
protected io.smallrye.mutiny.Multi<Message<? extends T>>	publisher
protected AtomicReference<Throwable>	synchronousFailure

Constructor Summary

Constructors

Constructor	Description
AbstractEmitter(EmitterConfiguration config, long defaultBufferSize)

Method Summary

Modifier and Type	Method	Description
void	complete()	Sends the completion event to the channel indicating that no other events will be sent afterward.
protected void	emit(Message<? extends T> message)
void	error(Exception e)	Sends a failure event to the channel.
org.reactivestreams.Publisher<Message<? extends T>>	getPublisher()
boolean	hasRequests()
boolean	isCancelled()

Methods inherited from class java.lang.Object

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

Field Detail

internal

protected final AtomicReference<io.smallrye.mutiny.subscription.MultiEmitter<? super Message<? extends T>>> internal

publisher

protected final io.smallrye.mutiny.Multi<Message<? extends T>> publisher

name

protected final String name

synchronousFailure

protected final AtomicReference<Throwable> synchronousFailure

Constructor Detail

AbstractEmitter

public AbstractEmitter(EmitterConfiguration config,
                       long defaultBufferSize)

Method Detail

complete

public void complete()

Description copied from interface: EmitterBehavior

Sends the completion event to the channel indicating that no other events will be sent afterward.

Specified by:

complete in interface EmitterBehavior

error

public void error(Exception e)

Description copied from interface: EmitterBehavior

Sends a failure event to the channel. No more events will be sent afterward.

Specified by:

error in interface EmitterBehavior

Parameters:

e - the exception, must not be null

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface EmitterBehavior

Returns:

true if the emitter has been terminated or the subscription cancelled.

hasRequests

public boolean hasRequests()

Specified by:

hasRequests in interface EmitterBehavior

Returns:

true if one or more subscribers request messages from the corresponding channel where the emitter connects to, return false otherwise.

getPublisher

public org.reactivestreams.Publisher<Message<? extends T>> getPublisher()

emit

protected void emit(Message<? extends T> message)