io.vertx.proton.streams.impl

Class ProtonPublisherImpl.AmqpSubscription

java.lang.Object

io.vertx.proton.streams.impl.ProtonPublisherImpl.AmqpSubscription

All Implemented Interfaces:

org.reactivestreams.Subscription

Enclosing class:

ProtonPublisherImpl

public class ProtonPublisherImpl.AmqpSubscription
extends Object
implements org.reactivestreams.Subscription

Constructor Summary

Constructors

Constructor and Description
AmqpSubscription(org.reactivestreams.Subscriber<? super Delivery> sub)

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	request(long n)

Methods inherited from class java.lang.Object

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

Constructor Detail

AmqpSubscription

public AmqpSubscription(org.reactivestreams.Subscriber<? super Delivery> sub)

Method Detail

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription