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

Class LegacyEmitterImpl<T>

java.lang.Object

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

Type Parameters:

T - the type of payload or message

All Implemented Interfaces:

Emitter<T>

public class LegacyEmitterImpl<T>
extends Object
implements Emitter<T>

Implementation of the old (legacy) Emitter interface. This implementation delegates to the new implementation.

Method Summary

Modifier and Type	Method	Description
void	complete()	Completes the stream.
void	error(Exception e)	Propagates an error in the stream.
boolean	isCancelled()
boolean	isRequested()
Emitter<T>	send(T msg)	Sends a payload or a message to the stream.

Methods inherited from class java.lang.Object

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

Method Detail

complete

public void complete()

Description copied from interface: Emitter

Completes the stream. This method sends the completion signal, no messages can be sent once this method is called.

Specified by:

complete in interface Emitter<T>

error

public void error(Exception e)

Description copied from interface: Emitter

Propagates an error in the stream. This methods sends an error signal, no messages can be sent once this method is called.

Specified by:

error in interface Emitter<T>

Parameters:

e - the exception, must not be null

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Emitter<T>

Returns:

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

isRequested

public boolean isRequested()

Specified by:

isRequested in interface Emitter<T>

Returns:

true if the subscriber accepts messages, false otherwise. Using Emitter.send(Object) on an emitter not expecting message would throw an IllegalStateException.

send

public Emitter<T> send(T msg)

Description copied from interface: Emitter

Sends a payload or a message to the stream.

Specified by:

send in interface Emitter<T>

Parameters:

msg - the thing to send, must not be null

Returns:

the current emitter