Package io.smallrye.reactive.messaging.providers.extension

Class PausableChannelDecorator.PauserChannel

java.lang.Object

io.smallrye.reactive.messaging.providers.extension.PausableChannelDecorator.PauserChannel

All Implemented Interfaces:

io.smallrye.reactive.messaging.PausableChannel

Enclosing class:

PausableChannelDecorator

public static class PausableChannelDecorator.PauserChannel
extends Object
implements io.smallrye.reactive.messaging.PausableChannel

Constructor Summary

Constructors

Constructor	Description
PauserChannel(io.smallrye.mutiny.subscription.DemandPauser pauser)

Method Summary

Modifier and Type	Method	Description
boolean	isPaused()
void	pause()
void	resume()

Methods inherited from class java.lang.Object

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

Constructor Details

PauserChannel

public PauserChannel(io.smallrye.mutiny.subscription.DemandPauser pauser)

Method Details

isPaused

public boolean isPaused()

Specified by:

isPaused in interface io.smallrye.reactive.messaging.PausableChannel

pause

public void pause()

Specified by:

pause in interface io.smallrye.reactive.messaging.PausableChannel

resume

public void resume()

Specified by:

resume in interface io.smallrye.reactive.messaging.PausableChannel