Top Inners Methods
io.rsocket.keepalive

public Interface KeepAliveHandler

Known Direct Implementers
io.rsocket.keepalive.KeepAliveHandler.DefaultKeepAliveHandler, io.rsocket.keepalive.KeepAliveHandler.ResumableKeepAliveHandler
Imports
io.netty.buffer.ByteBuf, io.rsocket.keepalive.KeepAliveSupport.KeepAlive, io.rsocket.resume.RSocketSession, .ResumableDuplexConnection, .ResumeStateHolder, java.util.function.Consumer

Nested and Inner Type Summary

Modifier and TypeClass and Description
public static class
KeepAliveHandler.DefaultKeepAliveHandler

public static class
KeepAliveHandler.ResumableKeepAliveHandler

Method Summary

Modifier and TypeMethod and Description
public KeepAliveFramesAcceptor
start(KeepAliveSupport keepAliveSupport, Consumer<ByteBuf> onFrameSent, Consumer<KeepAliveSupport.KeepAlive> onTimeout)

Method Detail

startback to summary
public KeepAliveFramesAcceptor start(KeepAliveSupport keepAliveSupport, Consumer<ByteBuf> onFrameSent, Consumer<KeepAliveSupport.KeepAlive> onTimeout)
io.rsocket.keepalive back to summary

public Class KeepAliveHandler.DefaultKeepAliveHandler

extends Object
implements KeepAliveHandler
Class Inheritance
  • java.lang.Object
  • io.rsocket.keepalive.KeepAliveHandler.DefaultKeepAliveHandler
All Implemented Interfaces
io.rsocket.keepalive.KeepAliveHandler

Constructor Summary

AccessConstructor and Description
public
DefaultKeepAliveHandler()

Method Summary

Modifier and TypeMethod and Description
public KeepAliveFramesAcceptor
start(KeepAliveSupport keepAliveSupport, Consumer<ByteBuf> onSendKeepAliveFrame, Consumer<KeepAliveSupport.KeepAlive> onTimeout)

Implements io.rsocket.keepalive.KeepAliveHandler.start.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

DefaultKeepAliveHandlerback to summary
public DefaultKeepAliveHandler()

Method Detail

startback to summary
public KeepAliveFramesAcceptor start(KeepAliveSupport keepAliveSupport, Consumer<ByteBuf> onSendKeepAliveFrame, Consumer<KeepAliveSupport.KeepAlive> onTimeout)

Implements io.rsocket.keepalive.KeepAliveHandler.start.

Annotations
@Override
io.rsocket.keepalive back to summary

public Class KeepAliveHandler.ResumableKeepAliveHandler

extends Object
implements KeepAliveHandler
Class Inheritance
  • java.lang.Object
  • io.rsocket.keepalive.KeepAliveHandler.ResumableKeepAliveHandler
All Implemented Interfaces
io.rsocket.keepalive.KeepAliveHandler

Field Summary

Modifier and TypeField and Description
private final ResumableDuplexConnection
resumableDuplexConnection

private final ResumeStateHolder
resumeStateHolder

private final RSocketSession
rSocketSession

Constructor Summary

AccessConstructor and Description
public
ResumableKeepAliveHandler(ResumableDuplexConnection resumableDuplexConnection, RSocketSession rSocketSession, ResumeStateHolder resumeStateHolder)

Method Summary

Modifier and TypeMethod and Description
public KeepAliveFramesAcceptor
start(KeepAliveSupport keepAliveSupport, Consumer<ByteBuf> onSendKeepAliveFrame, Consumer<KeepAliveSupport.KeepAlive> onTimeout)

Implements io.rsocket.keepalive.KeepAliveHandler.start.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

resumableDuplexConnectionback to summary
private final ResumableDuplexConnection resumableDuplexConnection
resumeStateHolderback to summary
private final ResumeStateHolder resumeStateHolder
rSocketSessionback to summary
private final RSocketSession rSocketSession

Constructor Detail

ResumableKeepAliveHandlerback to summary
public ResumableKeepAliveHandler(ResumableDuplexConnection resumableDuplexConnection, RSocketSession rSocketSession, ResumeStateHolder resumeStateHolder)

Method Detail

startback to summary
public KeepAliveFramesAcceptor start(KeepAliveSupport keepAliveSupport, Consumer<ByteBuf> onSendKeepAliveFrame, Consumer<KeepAliveSupport.KeepAlive> onTimeout)

Implements io.rsocket.keepalive.KeepAliveHandler.start.

Annotations
@Override