Top Fields Constructors Methods
io.rsocket.core

public final Class LeaseSpec

extends Object
Class Inheritance
Imports
io.rsocket.lease.LeaseSender, reactor.core.publisher.Flux

Field Summary

Modifier and TypeField and Description
pack-priv int
maxPendingRequests

pack-priv LeaseSender
sender

Constructor Summary

AccessConstructor and Description
pack-priv
LeaseSpec()

Method Summary

Modifier and TypeMethod and Description
public LeaseSpec
maxPendingRequests(int
if set to 0 the requester will terminate the request immediately if no leases is available
maxPendingRequests)

Setup the maximum queued requests waiting for lease to be available.

public LeaseSpec
sender(LeaseSender sender)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

maxPendingRequestsback to summary
pack-priv int maxPendingRequests
senderback to summary
pack-priv LeaseSender sender

Constructor Detail

LeaseSpecback to summary
pack-priv LeaseSpec()

Method Detail

maxPendingRequestsback to summary
public LeaseSpec maxPendingRequests(int maxPendingRequests)

Setup the maximum queued requests waiting for lease to be available. The default value is 256

Parameters
maxPendingRequests:int

if set to 0 the requester will terminate the request immediately if no leases is available

senderback to summary
public LeaseSpec sender(LeaseSender sender)