Modifier and Type	Class and Description
public static class	KeepAliveSupport.ClientKeepAliveSupport
public static class	KeepAliveSupport.KeepAlive

Field Summary

Modifier and Type	Field and Description
pack-priv final ByteBufAllocator	allocator
pack-priv static final int	DISPOSED_STATE
pack-priv final Duration	keepAliveInterval
pack-priv final Duration	keepAliveTimeout
pack-priv final long	keepAliveTimeoutMillis
pack-priv volatile long	lastReceivedMillis
pack-priv volatile Consumer<ByteBuf>	onFrameSent
pack-priv volatile Consumer<KeepAliveSupport.KeepAlive>	onTimeout
pack-priv volatile ResumeStateHolder	resumeStateHolder
pack-priv final Scheduler	scheduler
pack-priv static final int	STARTED_STATE
pack-priv static final int	STARTING_STATE
pack-priv volatile int	state
pack-priv static final AtomicIntegerFieldUpdater<KeepAliveSupport>	STATE
pack-priv static final int	STOPPED_STATE
pack-priv Disposable	ticksDisposable

Access	Constructor and Description
private	KeepAliveSupport(ByteBufAllocator allocator, int keepAliveInterval, int keepAliveTimeout)

Method Summary

Modifier and Type	Method and Description
public void	dispose() Implements reactor.core.Disposable.dispose. Cancel or dispose the underlying task or resource.
public boolean	isDisposed() Overrides default reactor.core.Disposable.isDisposed. Optionally return true when the resource or task is disposed.
pack-priv long	localLastReceivedPosition()
pack-priv abstract void	onIntervalTick()
public KeepAliveSupport	onSendKeepAliveFrame(Consumer<ByteBuf> onFrameSent)
public KeepAliveSupport	onTimeout(Consumer<KeepAliveSupport.KeepAlive> onTimeout)
public void	receive(ByteBuf keepAliveFrame) Implements io.rsocket.keepalive.KeepAliveFramesAcceptor.receive.
public KeepAliveSupport	resumeState(ResumeStateHolder resumeStateHolder)
pack-priv void	send(ByteBuf frame)
public KeepAliveSupport	start()
public void	stop()
pack-priv void	terminate(int terminationState)
pack-priv void	tryTimeout()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

allocator	back to summary
pack-priv final ByteBufAllocator allocator

DISPOSED_STATE	back to summary
pack-priv static final int DISPOSED_STATE

keepAliveInterval	back to summary
pack-priv final Duration keepAliveInterval

keepAliveTimeout	back to summary
pack-priv final Duration keepAliveTimeout

keepAliveTimeoutMillis	back to summary
pack-priv final long keepAliveTimeoutMillis

lastReceivedMillis	back to summary
pack-priv volatile long lastReceivedMillis

onFrameSent	back to summary
pack-priv volatile Consumer<ByteBuf> onFrameSent

onTimeout	back to summary
pack-priv volatile Consumer<KeepAliveSupport.KeepAlive> onTimeout

resumeStateHolder	back to summary
pack-priv volatile ResumeStateHolder resumeStateHolder

scheduler	back to summary
pack-priv final Scheduler scheduler

STARTED_STATE	back to summary
pack-priv static final int STARTED_STATE

STARTING_STATE	back to summary
pack-priv static final int STARTING_STATE

state	back to summary
pack-priv volatile int state

STATE	back to summary
pack-priv static final AtomicIntegerFieldUpdater<KeepAliveSupport> STATE

STOPPED_STATE	back to summary
pack-priv static final int STOPPED_STATE

ticksDisposable	back to summary
pack-priv Disposable ticksDisposable

Constructor Detail

KeepAliveSupport	back to summary
private KeepAliveSupport(ByteBufAllocator allocator, int keepAliveInterval, int keepAliveTimeout)

Method Detail

dispose	back to summary
public void dispose() Implements reactor.core.Disposable.dispose. Doc from reactor.core.Disposable.dispose. Cancel or dispose the underlying task or resource. Implementations are required to make this method idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Implements reactor.core.Disposable.dispose.

Doc from reactor.core.Disposable.dispose.

Cancel or dispose the underlying task or resource.

Implementations are required to make this method idempotent.

Annotations

@Override

isDisposed	back to summary
public boolean isDisposed() Overrides default reactor.core.Disposable.isDisposed. Doc from reactor.core.Disposable.isDisposed. Optionally return true when the resource or task is disposed. Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed. Returns:boolean true when there's a guarantee the resource or task is disposed. Annotations @Override

isDisposed

back to summary

public boolean isDisposed()

Overrides default reactor.core.Disposable.isDisposed.

Doc from reactor.core.Disposable.isDisposed.

Optionally return true when the resource or task is disposed.

Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed.

Returns:boolean

true when there's a guarantee the resource or task is disposed.

Annotations

@Override

localLastReceivedPosition	back to summary
pack-priv long localLastReceivedPosition()

onIntervalTick	back to summary
pack-priv abstract void onIntervalTick()

onSendKeepAliveFrame	back to summary
public KeepAliveSupport onSendKeepAliveFrame(Consumer<ByteBuf> onFrameSent)

onTimeout	back to summary
public KeepAliveSupport onTimeout(Consumer<KeepAliveSupport.KeepAlive> onTimeout)

receive	back to summary
public void receive(ByteBuf keepAliveFrame) Implements io.rsocket.keepalive.KeepAliveFramesAcceptor.receive. Annotations @Override

receive

back to summary

public void receive(ByteBuf keepAliveFrame)

Implements io.rsocket.keepalive.KeepAliveFramesAcceptor.receive.

Annotations

@Override

resumeState	back to summary
public KeepAliveSupport resumeState(ResumeStateHolder resumeStateHolder)

send	back to summary
pack-priv void send(ByteBuf frame)

start	back to summary
public KeepAliveSupport start()

stop	back to summary
public void stop()

terminate	back to summary
pack-priv void terminate(int terminationState)

tryTimeout	back to summary
pack-priv void tryTimeout()

io.rsocket.keepalive back to summary

public final Class KeepAliveSupport.ClientKeepAliveSupport

Class Inheritance

extends KeepAliveSupport

java.lang.Object
io.rsocket.keepalive.KeepAliveSupport
io.rsocket.keepalive.KeepAliveSupport.ClientKeepAliveSupport

Field Summary

Inherited from io.rsocket.keepalive.KeepAliveSupport:: allocator DISPOSED_STATE keepAliveInterval keepAliveTimeout keepAliveTimeoutMillis lastReceivedMillis onFrameSent onTimeout resumeStateHolder scheduler STARTED_STATE STARTING_STATE state STATE STOPPED_STATE ticksDisposable

Constructor Summary

Access	Constructor and Description
public	ClientKeepAliveSupport(ByteBufAllocator allocator, int keepAliveInterval, int keepAliveTimeout)

Method Summary

Modifier and Type	Method and Description
pack-priv void	onIntervalTick() Implements abstract io.rsocket.keepalive.KeepAliveSupport.onIntervalTick.

Inherited from io.rsocket.keepalive.KeepAliveSupport:: dispose isDisposed localLastReceivedPosition onSendKeepAliveFrame onTimeout receive resumeState send start stop terminate tryTimeout

Constructor Detail

ClientKeepAliveSupport	back to summary
public ClientKeepAliveSupport(ByteBufAllocator allocator, int keepAliveInterval, int keepAliveTimeout)

Method Detail

onIntervalTick	back to summary
pack-priv void onIntervalTick() Implements abstract io.rsocket.keepalive.KeepAliveSupport.onIntervalTick. Annotations @Override

onIntervalTick

back to summary

pack-priv void onIntervalTick()

Implements abstract io.rsocket.keepalive.KeepAliveSupport.onIntervalTick.

Annotations

@Override

io.rsocket.keepalive back to summary

public final Class KeepAliveSupport.KeepAlive

Class Inheritance

extends Object

java.lang.Object
io.rsocket.keepalive.KeepAliveSupport.KeepAlive

Field Summary

Modifier and Type	Field and Description
private final Duration	tickPeriod
private final Duration	timeoutMillis

Constructor Summary

Access	Constructor and Description
public	KeepAlive(Duration tickPeriod, Duration timeoutMillis)

Method Summary

Modifier and Type	Method and Description
public Duration	getTickPeriod()
public Duration	getTimeout()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

tickPeriod	back to summary
private final Duration tickPeriod

timeoutMillis	back to summary
private final Duration timeoutMillis

Constructor Detail

KeepAlive	back to summary
public KeepAlive(Duration tickPeriod, Duration timeoutMillis)

Method Detail

getTickPeriod	back to summary
public Duration getTickPeriod()

getTimeout	back to summary
public Duration getTimeout()

public abstract Class KeepAliveSupport

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public final Class KeepAliveSupport.ClientKeepAliveSupport

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

public final Class KeepAliveSupport.KeepAlive

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail