Top Description Methods
io.rsocket.core

pack-priv Interface LeasePermitHandler

Known Direct Implementers
io.rsocket.core.RequestChannelRequesterFlux, io.rsocket.core.RequestResponseRequesterMono, io.rsocket.core.RequestStreamRequesterFlux, io.rsocket.core.SlowFireAndForgetRequesterMono
Handler which enables async lease permits issuing

Method Summary

Modifier and TypeMethod and Description
public boolean

Returns:

true to indicate that lease permit was consumed successfully
handlePermit()

Called by RequesterLeaseTracker when there is an available lease

public void
handlePermitError(Throwable
associated lease permit rejection exception
t)

Called by RequesterLeaseTracker when there are no lease permit available at the moment and the list of awaiting LeasePermitHandler reached the configured limit

Method Detail

handlePermitback to summary
public boolean handlePermit()

Called by RequesterLeaseTracker when there is an available lease

Returns:boolean

true to indicate that lease permit was consumed successfully

handlePermitErrorback to summary
public void handlePermitError(Throwable t)

Called by RequesterLeaseTracker when there are no lease permit available at the moment and the list of awaiting LeasePermitHandler reached the configured limit

Parameters
t:Throwable

associated lease permit rejection exception