io.rsocket.resume

Class ServerRSocketSession

java.lang.Object

io.rsocket.resume.ServerRSocketSession

All Implemented Interfaces:

Closeable, RSocketSession<DuplexConnection>, Disposable

public class ServerRSocketSession
extends Object
implements RSocketSession<DuplexConnection>

Nested Class Summary

Nested classes/interfaces inherited from interface reactor.core.Disposable

Disposable.Composite, Disposable.Swap

Constructor Summary

Constructors

Constructor and Description
ServerRSocketSession(DuplexConnection duplexConnection, ByteBufAllocator allocator, Duration resumeSessionDuration, Duration resumeStreamTimeout, Function<? super ByteBuf,? extends ResumableFramesStore> resumeStoreFactory, ByteBuf resumeToken, boolean cleanupStoreOnKeepAlive)

Method Summary

Modifier and Type	Method and Description
ServerRSocketSession	continueWith(DuplexConnection connectionFactory)
void	reconnect(DuplexConnection connection)
ResumableDuplexConnection	resumableConnection()
ServerRSocketSession	resumeWith(ByteBuf resumeFrame)
ByteBuf	token()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.rsocket.resume.RSocketSession

dispose, isDisposed, onClose

Constructor Detail

ServerRSocketSession

public ServerRSocketSession(DuplexConnection duplexConnection,
                            ByteBufAllocator allocator,
                            Duration resumeSessionDuration,
                            Duration resumeStreamTimeout,
                            Function<? super ByteBuf,? extends ResumableFramesStore> resumeStoreFactory,
                            ByteBuf resumeToken,
                            boolean cleanupStoreOnKeepAlive)

Method Detail

continueWith

public ServerRSocketSession continueWith(DuplexConnection connectionFactory)

Specified by:

continueWith in interface RSocketSession<DuplexConnection>

resumeWith

public ServerRSocketSession resumeWith(ByteBuf resumeFrame)

Specified by:

resumeWith in interface RSocketSession<DuplexConnection>

reconnect

public void reconnect(DuplexConnection connection)

Specified by:

reconnect in interface RSocketSession<DuplexConnection>

resumableConnection

public ResumableDuplexConnection resumableConnection()

Specified by:

resumableConnection in interface RSocketSession<DuplexConnection>

token

public ByteBuf token()

Specified by:

token in interface RSocketSession<DuplexConnection>