Package io.micronaut.core.async.subscriber

Interface Emitter<T>

Type Parameters:

T - type of element

All Superinterfaces:

Completable

All Known Implementing Classes:

CompletionAwareSubscriber, JacksonCoreProcessor, JacksonProcessor, SingleSubscriberProcessor, SingleThreadedBufferingProcessor, SingleThreadedBufferingSubscriber, TypedSubscriber

public interface Emitter<T>
extends Completable

Base interface for classes that emit data. See Subscriber.

Since:

1.0

Author:

Graeme Rocher

Method Summary

Modifier and Type	Method	Description
void	onError(Throwable t)	Failed terminal state.
void	onNext(T t)	Data notification sent by the Publisher in response to requests to Subscription.request(long).

Methods inherited from interface io.micronaut.core.async.subscriber.Completable

onComplete

Method Details

onNext

void onNext(T t)

Data notification sent by the Publisher in response to requests to Subscription.request(long).

Parameters:

t - the element signaled

onError

void onError(Throwable t)

Failed terminal state.

No further events will be sent even if Subscription.request(long) is invoked again.

Parameters:

t - the throwable signaled