Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	ServerSetup.DefaultServerSetup
pack-priv static class	ServerSetup.ResumableServerSetup

Field Summary

Modifier and Type	Field and Description
pack-priv final Duration	timeout

Access	Constructor and Description
protected	ServerSetup(Duration timeout)

Method Summary

Modifier and Type	Method and Description
pack-priv abstract Mono<Void>	acceptRSocketResume(ByteBuf frame, DuplexConnection connection)
pack-priv abstract Mono<Void>	acceptRSocketSetup(ByteBuf frame, DuplexConnection clientServerConnection, BiFunction<KeepAliveHandler, DuplexConnection, Mono<Void>> then)
pack-priv void	dispose()
pack-priv Mono<Tuple2<ByteBuf, DuplexConnection>>	init(DuplexConnection connection)
pack-priv void	sendError(DuplexConnection duplexConnection, RSocketErrorException exception)

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

Field Detail

timeout	back to summary
pack-priv final Duration timeout

ServerSetup	back to summary
protected ServerSetup(Duration timeout)

Method Detail

acceptRSocketResume	back to summary
pack-priv abstract Mono<Void> acceptRSocketResume(ByteBuf frame, DuplexConnection connection)

acceptRSocketSetup	back to summary
pack-priv abstract Mono<Void> acceptRSocketSetup(ByteBuf frame, DuplexConnection clientServerConnection, BiFunction<KeepAliveHandler, DuplexConnection, Mono<Void>> then)

dispose	back to summary
pack-priv void dispose()

init	back to summary
pack-priv Mono<Tuple2<ByteBuf, DuplexConnection>> init(DuplexConnection connection)

sendError	back to summary
pack-priv void sendError(DuplexConnection duplexConnection, RSocketErrorException exception)

io.rsocket.core back to summary

pack-priv Class ServerSetup.DefaultServerSetup

Class Inheritance

extends ServerSetup

java.lang.Object
io.rsocket.core.ServerSetup
io.rsocket.core.ServerSetup.DefaultServerSetup

Field Summary

Inherited from io.rsocket.core.ServerSetup:: timeout

Constructor Summary

Access	Constructor and Description
pack-priv	DefaultServerSetup(Duration timeout)

Method Summary

Modifier and Type	Method and Description
public Mono<Void>	acceptRSocketResume(ByteBuf frame, DuplexConnection duplexConnection) Implements abstract io.rsocket.core.ServerSetup.acceptRSocketResume.
public Mono<Void>	acceptRSocketSetup(ByteBuf frame, DuplexConnection duplexConnection, BiFunction<KeepAliveHandler, DuplexConnection, Mono<Void>> then) Implements abstract io.rsocket.core.ServerSetup.acceptRSocketSetup.

Inherited from io.rsocket.core.ServerSetup:: dispose init sendError

Constructor Detail

DefaultServerSetup	back to summary
pack-priv DefaultServerSetup(Duration timeout)

Method Detail

acceptRSocketResume	back to summary
public Mono<Void> acceptRSocketResume(ByteBuf frame, DuplexConnection duplexConnection) Implements abstract io.rsocket.core.ServerSetup.acceptRSocketResume. Annotations @Override

acceptRSocketResume

back to summary

public Mono<Void> acceptRSocketResume(ByteBuf frame, DuplexConnection duplexConnection)

Implements abstract io.rsocket.core.ServerSetup.acceptRSocketResume.

Annotations

@Override

acceptRSocketSetup	back to summary
public Mono<Void> acceptRSocketSetup(ByteBuf frame, DuplexConnection duplexConnection, BiFunction<KeepAliveHandler, DuplexConnection, Mono<Void>> then) Implements abstract io.rsocket.core.ServerSetup.acceptRSocketSetup. Annotations @Override

acceptRSocketSetup

back to summary

public Mono<Void> acceptRSocketSetup(ByteBuf frame, DuplexConnection duplexConnection, BiFunction<KeepAliveHandler, DuplexConnection, Mono<Void>> then)

Implements abstract io.rsocket.core.ServerSetup.acceptRSocketSetup.

Annotations

@Override

io.rsocket.core back to summary

pack-priv Class ServerSetup.ResumableServerSetup

Class Inheritance

extends ServerSetup

java.lang.Object
io.rsocket.core.ServerSetup
io.rsocket.core.ServerSetup.ResumableServerSetup

Field Summary

Modifier and Type	Field and Description
private final boolean	cleanupStoreOnKeepAlive
private final Duration	resumeSessionDuration
private final Function<? super ByteBuf, ? extends ResumableFramesStore>	resumeStoreFactory
private final Duration	resumeStreamTimeout
private final SessionManager	sessionManager

Inherited from io.rsocket.core.ServerSetup:: timeout

Constructor Summary

Access	Constructor and Description
pack-priv	ResumableServerSetup(Duration timeout, SessionManager sessionManager, Duration resumeSessionDuration, Duration resumeStreamTimeout, Function<? super ByteBuf, ? extends ResumableFramesStore> resumeStoreFactory, boolean cleanupStoreOnKeepAlive)

Method Summary

Modifier and Type	Method and Description
public Mono<Void>	acceptRSocketResume(ByteBuf frame, DuplexConnection duplexConnection) Implements abstract io.rsocket.core.ServerSetup.acceptRSocketResume.
public Mono<Void>	acceptRSocketSetup(ByteBuf frame, DuplexConnection duplexConnection, BiFunction<KeepAliveHandler, DuplexConnection, Mono<Void>> then) Implements abstract io.rsocket.core.ServerSetup.acceptRSocketSetup.
public void	dispose() Overrides io.rsocket.core.ServerSetup.dispose.

Inherited from io.rsocket.core.ServerSetup:: init sendError

Field Detail

cleanupStoreOnKeepAlive	back to summary
private final boolean cleanupStoreOnKeepAlive

resumeSessionDuration	back to summary
private final Duration resumeSessionDuration

resumeStoreFactory	back to summary
private final Function<? super ByteBuf, ? extends ResumableFramesStore> resumeStoreFactory

resumeStreamTimeout	back to summary
private final Duration resumeStreamTimeout

sessionManager	back to summary
private final SessionManager sessionManager

Constructor Detail

ResumableServerSetup	back to summary
pack-priv ResumableServerSetup(Duration timeout, SessionManager sessionManager, Duration resumeSessionDuration, Duration resumeStreamTimeout, Function<? super ByteBuf, ? extends ResumableFramesStore> resumeStoreFactory, boolean cleanupStoreOnKeepAlive)

Method Detail

acceptRSocketResume	back to summary
public Mono<Void> acceptRSocketResume(ByteBuf frame, DuplexConnection duplexConnection) Implements abstract io.rsocket.core.ServerSetup.acceptRSocketResume. Annotations @Override

acceptRSocketResume

back to summary

public Mono<Void> acceptRSocketResume(ByteBuf frame, DuplexConnection duplexConnection)

Implements abstract io.rsocket.core.ServerSetup.acceptRSocketResume.

Annotations

@Override

acceptRSocketSetup	back to summary
public Mono<Void> acceptRSocketSetup(ByteBuf frame, DuplexConnection duplexConnection, BiFunction<KeepAliveHandler, DuplexConnection, Mono<Void>> then) Implements abstract io.rsocket.core.ServerSetup.acceptRSocketSetup. Annotations @Override

acceptRSocketSetup

back to summary