Subscriber

Undocumented in source.

interface Subscriber (

T

) {

void onSubscribe(Subscription var1);

void onNext(T var1);

void onError(Throwable var1);

void onComplete();

}

Members

Functions

onComplete void onComplete(): Undocumented in source.
onError void onError(Throwable var1): Undocumented in source.
onNext void onNext(T var1): Undocumented in source.
onSubscribe void onSubscribe(Subscription var1): Undocumented in source.

Meta

Source

See Implementation

hunt amqp streams Subscriber interfaces

Subscriber