hunt-amqp ~master (2020-09-22T10:53:41Z)

ProtonPublisherWrapperImpl.AmqpSubscriberWrapperImpl

hunt amqp streams impl ProtonPublisherWrapperImpl ProtonPublisherWrapperImpl
Undocumented in source.
class ProtonPublisherWrapperImpl
class AmqpSubscriberWrapperImpl : Subscriber!Delivery {
this(Subscriber!Message subscriber);
void onSubscribe(Subscription s);
void onNext(Delivery d);
void onError(Throwable t);
void onComplete();
}

Constructors

this
this(Subscriber!Message subscriber)
Undocumented in source.

Members

Functions

onComplete
void onComplete()
Undocumented in source. Be warned that the author may not have intended to support it.
onError
void onError(Throwable t)
Undocumented in source. Be warned that the author may not have intended to support it.
onNext
void onNext(Delivery d)
Undocumented in source. Be warned that the author may not have intended to support it.
onSubscribe
void onSubscribe(Subscription s)
Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation

hunt amqp streams impl ProtonPublisherWrapperImpl ProtonPublisherWrapperImpl classesconstructorsfunctions

Page generated by adrdox