io.rsocket.resume

Class ClientRSocketSession

java.lang.Object

io.rsocket.resume.ClientRSocketSession

All Implemented Interfaces:

Closeable, RSocketSession<Mono<DuplexConnection>>, Disposable

public class ClientRSocketSession
extends Object
implements RSocketSession<Mono<DuplexConnection>>

Nested Class Summary

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

Disposable.Composite, Disposable.Swap

Constructor Summary

Constructors

Constructor and Description
ClientRSocketSession(DuplexConnection duplexConnection, Duration resumeSessionDuration, Retry retry, ResumableFramesStore resumableFramesStore, Duration resumeStreamTimeout, boolean cleanupStoreOnKeepAlive)

Method Summary

Modifier and Type	Method and Description
ClientRSocketSession	continueWith(Mono<DuplexConnection> connectionFactory)
void	reconnect(DuplexConnection connection)
ResumableDuplexConnection	resumableConnection()
ClientRSocketSession	resumeToken(ByteBuf resumeToken)
ClientRSocketSession	resumeWith(ByteBuf resumeOkFrame)
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

ClientRSocketSession

public ClientRSocketSession(DuplexConnection duplexConnection,
                            Duration resumeSessionDuration,
                            Retry retry,
                            ResumableFramesStore resumableFramesStore,
                            Duration resumeStreamTimeout,
                            boolean cleanupStoreOnKeepAlive)

Method Detail

continueWith

public ClientRSocketSession continueWith(Mono<DuplexConnection> connectionFactory)

Specified by:

continueWith in interface RSocketSession<Mono<DuplexConnection>>

resumeWith

public ClientRSocketSession resumeWith(ByteBuf resumeOkFrame)

Specified by:

resumeWith in interface RSocketSession<Mono<DuplexConnection>>

resumeToken

public ClientRSocketSession resumeToken(ByteBuf resumeToken)

reconnect

public void reconnect(DuplexConnection connection)

Specified by:

reconnect in interface RSocketSession<Mono<DuplexConnection>>

resumableConnection

public ResumableDuplexConnection resumableConnection()

Specified by:

resumableConnection in interface RSocketSession<Mono<DuplexConnection>>

token

public ByteBuf token()

Specified by:

token in interface RSocketSession<Mono<DuplexConnection>>