Top Inners Fields Constructors Methods
io.rsocket.core

pack-priv final Class ResponderLeaseTracker

extends BaseSubscriber<Lease>
implements Disposable, Availability
Class Inheritance
All Implemented Interfaces
io.rsocket.Availability, reactor.core.Disposable
Imports
io.netty.buffer.ByteBufAllocator, io.rsocket.Availability, .DuplexConnection, io.rsocket.frame.LeaseFrameCodec, io.rsocket.lease.Lease, .LeaseSender, .MissingLeaseException, reactor.core.Disposable, reactor.core.publisher.BaseSubscriber, reactor.util.annotation.Nullable

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
ResponderLeaseTracker.MutableLease

Field Summary

Modifier and TypeField and Description
pack-priv final ByteBufAllocator
allocator

pack-priv final DuplexConnection
connection

pack-priv volatile ResponderLeaseTracker.MutableLease
currentLease

pack-priv final String
tag

Constructor Summary

AccessConstructor and Description
pack-priv
ResponderLeaseTracker(String tag, DuplexConnection connection, LeaseSender leaseSender)

Method Summary

Modifier and TypeMethod and Description
public double
availability()

Implements io.rsocket.Availability.availability.

protected void
hookOnNext(Lease
the emitted value to process
lease)

Overrides reactor.core.publisher.BaseSubscriber.hookOnNext.

Hook for processing of onNext values.
pack-priv static boolean
isExpired(ResponderLeaseTracker.MutableLease currentLease)

pack-priv Throwable
use()

Inherited from reactor.core.publisher.BaseSubscriber:
canceldisposehookFinallyhookOnCancelhookOnCompletehookOnErrorhookOnSubscribeisDisposedonCompleteonErroronNextonSubscriberequestrequestUnboundedtoStringupstream

Field Detail

allocatorback to summary
pack-priv final ByteBufAllocator allocator
connectionback to summary
pack-priv final DuplexConnection connection
currentLeaseback to summary
pack-priv volatile ResponderLeaseTracker.MutableLease currentLease
Annotations
@Nullable
tagback to summary
pack-priv final String tag

Constructor Detail

ResponderLeaseTrackerback to summary
pack-priv ResponderLeaseTracker(String tag, DuplexConnection connection, LeaseSender leaseSender)

Method Detail

availabilityback to summary
public double availability()

Implements io.rsocket.Availability.availability.

Returns:double

Doc from io.rsocket.Availability.availability.

a positive numbers representing the availability of the entity. Higher is better, 0.0 means not available

Annotations
@Override
hookOnNextback to summary
protected void hookOnNext(Lease lease)

Overrides reactor.core.publisher.BaseSubscriber.hookOnNext.

Doc from reactor.core.publisher.BaseSubscriber.hookOnNext.

Hook for processing of onNext values. You can call request(long) here to further request data from the source org.reactivestreams.Publisher if the initial request wasn't unbounded.

Defaults to doing nothing.

Parameters
lease:Lease

the emitted value to process

Annotations
@Override
isExpiredback to summary
pack-priv static boolean isExpired(ResponderLeaseTracker.MutableLease currentLease)
useback to summary
pack-priv Throwable use()
Annotations
@Nullable
io.rsocket.core back to summary

pack-priv final Class ResponderLeaseTracker.MutableLease

extends Object
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final int
allowedRequests

pack-priv final long
expireAt

pack-priv int
remainingRequests

Constructor Summary

AccessConstructor and Description
pack-priv
MutableLease(int allowedRequests, long expireAt)

Method Summary

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

allowedRequestsback to summary
pack-priv final int allowedRequests
expireAtback to summary
pack-priv final long expireAt
remainingRequestsback to summary
pack-priv int remainingRequests

Constructor Detail

MutableLeaseback to summary
pack-priv MutableLease(int allowedRequests, long expireAt)