io.rsocket.resume

Interface ResumableFramesStore

All Superinterfaces:

Closeable, Disposable

All Known Implementing Classes:

InMemoryResumableFramesStore

public interface ResumableFramesStore
extends Closeable

Store for resumable frames

Nested Class Summary

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

Disposable.Composite, Disposable.Swap

Method Summary

Modifier and Type	Method and Description
long	frameImpliedPosition()
long	framePosition()
void	releaseFrames(long remoteImpliedPos) Release frames from tail of the store up to remote implied position
void	resumableFrameReceived(ByteBuf frame) Received resumable frame as defined by RSocket protocol.
Flux<ByteBuf>	resumeStream()
Mono<Void>	saveFrames(Flux<ByteBuf> frames) Save resumable frames for potential resumption

Methods inherited from interface io.rsocket.Closeable

onClose

Methods inherited from interface reactor.core.Disposable

dispose, isDisposed

Method Detail

saveFrames

Mono<Void> saveFrames(Flux<ByteBuf> frames)

Save resumable frames for potential resumption

Parameters:

frames - Flux of resumable frames

Returns:

Mono which completes once all resume frames are written

releaseFrames

void releaseFrames(long remoteImpliedPos)

Release frames from tail of the store up to remote implied position

resumeStream

Flux<ByteBuf> resumeStream()

Returns:

Flux of frames from store tail to head. It should terminate with error if frames are not continuous

framePosition

long framePosition()

Returns:

Local frame position as defined by RSocket protocol

frameImpliedPosition

long frameImpliedPosition()

Returns:

Implied frame position as defined by RSocket protocol

resumableFrameReceived

void resumableFrameReceived(ByteBuf frame)

Received resumable frame as defined by RSocket protocol. Implementation must increment frame implied position