public abstract class AbstractEmitter<T>
extends Object

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`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`complete()`
`protected void`	`emit(Message<? extends T> message)`
`void`	`error(Exception e)`
`org.reactivestreams.Publisher<Message<? extends T>>`	`getPublisher()`
`boolean`	`hasRequests()`
`boolean`	`isCancelled()`

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

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

protected final AtomicReference<Throwable> synchronousFailure

public AbstractEmitter(EmitterConfiguration config,
                       long defaultBufferSize)

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

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

Class AbstractEmitter<T>