rsocket-core 1.1.4 · io.rsocket.core.RequestStreamRequesterFlux

Modifier and Type	Field and Description
pack-priv final ByteBufAllocator	allocator
pack-priv final DuplexConnection	connection
pack-priv boolean	done
pack-priv CompositeByteBuf	frames
pack-priv CoreSubscriber<? super Payload>	inboundSubscriber
pack-priv final int	maxFrameLength
pack-priv final int	maxInboundPayloadSize
pack-priv final int	mtu
pack-priv final Payload	payload
pack-priv final PayloadDecoder	payloadDecoder
pack-priv long	produced
pack-priv long	requested
pack-priv final RequesterLeaseTracker	requesterLeaseTracker
pack-priv final RequesterResponderSupport	requesterResponderSupport
pack-priv final RequestInterceptor	requestInterceptor
pack-priv volatile long	state
pack-priv static final AtomicLongFieldUpdater<RequestStreamRequesterFlux>	STATE
pack-priv int	streamId

Access	Constructor and Description
pack-priv	RequestStreamRequesterFlux(Payload payload, RequesterResponderSupport requesterResponderSupport)

Modifier and Type	Method and Description
public final void	cancel() Implements org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources.
public CompositeByteBuf	getFrames() Implements io.rsocket.core.RequesterFrameHandler.getFrames.
public final void	handleComplete() Implements io.rsocket.core.FrameHandler.handleComplete.
public final void	handleError(Throwable cause) Implements io.rsocket.core.FrameHandler.handleError.
public void	handleNext(ByteBuf frame, boolean hasFollows, boolean isLastPayload) Implements io.rsocket.core.FrameHandler.handleNext.
public final void	handlePayload(Payload p) Implements io.rsocket.core.RequesterFrameHandler.handlePayload.
public boolean	handlePermit() Implements io.rsocket.core.LeasePermitHandler.handlePermit. Called by `RequesterLeaseTracker` when there is an available lease
public final void	handlePermitError(Throwable associated lease permit rejection exception cause) Implements io.rsocket.core.LeasePermitHandler.handlePermitError. Called by `RequesterLeaseTracker` when there are no lease permit available at the moment and the list of awaiting `LeasePermitHandler` reached the configured limit
public final void	request(long the strictly positive number of elements to requests to the upstream `Publisher` n) Implements org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method.
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Implements reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.
pack-priv void	sendFirstPayload(Payload payload, long initialRequestN)
public void	setFrames(CompositeByteBuf byteBuf) Implements io.rsocket.core.RequesterFrameHandler.setFrames.
public String	stepName() Overrides default reactor.core.Scannable.stepName. Return a meaningful `String` representation of this `Scannable` in its chain of `parents()` and `actuals()`.
public void	subscribe(CoreSubscriber<? super Payload> the `Subscriber` interested into the published sequence actual) Implements abstract reactor.core.publisher.Flux.subscribe. Implements reactor.core.CorePublisher.subscribe. An internal `Publisher#subscribe(Subscriber)` that will bypass `Hooks#onLastOperator(Function)` pointcut.

allocator	back to summary
pack-priv final ByteBufAllocator allocator

connection	back to summary
pack-priv final DuplexConnection connection

done	back to summary
pack-priv boolean done

frames	back to summary
pack-priv CompositeByteBuf frames

inboundSubscriber	back to summary
pack-priv CoreSubscriber<? super Payload> inboundSubscriber

maxFrameLength	back to summary
pack-priv final int maxFrameLength

maxInboundPayloadSize	back to summary
pack-priv final int maxInboundPayloadSize

mtu	back to summary
pack-priv final int mtu

payload	back to summary
pack-priv final Payload payload

payloadDecoder	back to summary
pack-priv final PayloadDecoder payloadDecoder

produced	back to summary
pack-priv long produced

requested	back to summary
pack-priv long requested

requesterLeaseTracker	back to summary
pack-priv final RequesterLeaseTracker requesterLeaseTracker Annotations @Nullable

requesterResponderSupport	back to summary
pack-priv final RequesterResponderSupport requesterResponderSupport

requestInterceptor	back to summary
pack-priv final RequestInterceptor requestInterceptor Annotations @Nullable

state	back to summary
pack-priv volatile long state

STATE	back to summary
pack-priv static final AtomicLongFieldUpdater<RequestStreamRequesterFlux> STATE

streamId	back to summary
pack-priv int streamId

RequestStreamRequesterFlux	back to summary
pack-priv RequestStreamRequesterFlux(Payload payload, RequesterResponderSupport requesterResponderSupport)

Method Detail

cancel back to summary

cancel	back to summary
public final void cancel() Implements org.reactivestreams.Subscription.cancel. Doc from org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources. Data may still be sent to meet previously signalled demand after calling cancel. Annotations @Override

public final void cancel()

Implements org.reactivestreams.Subscription.cancel.

Doc from org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Annotations

@Override

getFrames	back to summary
public CompositeByteBuf getFrames() Implements io.rsocket.core.RequesterFrameHandler.getFrames. Annotations @Override

getFrames

back to summary

public CompositeByteBuf getFrames()

Implements io.rsocket.core.RequesterFrameHandler.getFrames.

Annotations

@Override

handleComplete	back to summary
public final void handleComplete() Implements io.rsocket.core.FrameHandler.handleComplete. Annotations @Override

handleComplete

back to summary

public final void handleComplete()

Implements io.rsocket.core.FrameHandler.handleComplete.

Annotations

@Override

handleError	back to summary
public final void handleError(Throwable cause) Implements io.rsocket.core.FrameHandler.handleError. Annotations @Override

handleError

back to summary

public final void handleError(Throwable cause)

Implements io.rsocket.core.FrameHandler.handleError.

Annotations

@Override

handleNext	back to summary
public void handleNext(ByteBuf frame, boolean hasFollows, boolean isLastPayload) Implements io.rsocket.core.FrameHandler.handleNext. Annotations @Override

handleNext

back to summary

public void handleNext(ByteBuf frame, boolean hasFollows, boolean isLastPayload)

Implements io.rsocket.core.FrameHandler.handleNext.

Annotations

@Override

handlePayload	back to summary
public final void handlePayload(Payload p) Implements io.rsocket.core.RequesterFrameHandler.handlePayload. Annotations @Override

handlePayload

back to summary

public final void handlePayload(Payload p)

Implements io.rsocket.core.RequesterFrameHandler.handlePayload.

Annotations

@Override

handlePermit back to summary

handlePermit	back to summary
public boolean handlePermit() Implements io.rsocket.core.LeasePermitHandler.handlePermit. Doc from io.rsocket.core.LeasePermitHandler.handlePermit. Called by `RequesterLeaseTracker` when there is an available lease Returns:boolean `true` to indicate that lease permit was consumed successfully Annotations @Override

public boolean handlePermit()

Implements io.rsocket.core.LeasePermitHandler.handlePermit.

Doc from io.rsocket.core.LeasePermitHandler.handlePermit.

Called by RequesterLeaseTracker when there is an available lease

Returns:boolean

true to indicate that lease permit was consumed successfully

Annotations

@Override

handlePermitError back to summary

handlePermitError	back to summary
public final void handlePermitError(Throwable cause) Implements io.rsocket.core.LeasePermitHandler.handlePermitError. Doc from io.rsocket.core.LeasePermitHandler.handlePermitError. Called by `RequesterLeaseTracker` when there are no lease permit available at the moment and the list of awaiting `LeasePermitHandler` reached the configured limit Parameters cause:Throwable associated lease permit rejection exception Annotations @Override

public final void handlePermitError(Throwable cause)

Implements io.rsocket.core.LeasePermitHandler.handlePermitError.

Doc from io.rsocket.core.LeasePermitHandler.handlePermitError.

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

Parameters

cause:Throwable: associated lease permit rejection exception

Annotations

@Override

request back to summary

request	back to summary
public final void request(long n) Implements org.reactivestreams.Subscription.request. Doc from org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method. It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the `Publisher` as "effectively unbounded". Whatever has been requested can be sent by the `Publisher` so only signal demand for what can be safely handled. A `Publisher` can send less than is requested if the stream ends but then must emit either `Subscriber#onError(Throwable)` or `Subscriber#onComplete()`. Parameters n:long the strictly positive number of elements to requests to the upstream `Publisher` Annotations @Override

public final void request(long n)

Implements org.reactivestreams.Subscription.request.

Doc from org.reactivestreams.Subscription.request.

No events will be sent by a Publisher until demand is signaled via this method.

It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the Publisher as "effectively unbounded".

Whatever has been requested can be sent by the Publisher so only signal demand for what can be safely handled.

A Publisher can send less than is requested if the stream ends but then must emit either Subscriber#onError(Throwable) or Subscriber#onComplete().

Parameters

n:long: the strictly positive number of elements to requests to the upstream Publisher

Annotations

@Override

scanUnsafe back to summary

scanUnsafe	back to summary
public Object scanUnsafe(Scannable.Attr<T> key) Implements reactor.core.Scannable.scanUnsafe. Doc from reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the `Attr` key, implementors should take care to return values of the correct type, and return null if no specific value is available. For public consumption of attributes, prefer using `scan(Attr)`, which will return a typed value and fall back to the key's default if the component didn't define any mapping. Parameters key:Scannable.Attr<T> a `Attr` to resolve for the component. Returns:Object the value associated to the key for that specific component, or null if none. Annotations @Override @Nullable

public Object scanUnsafe(Scannable.Attr<T> key)

Implements reactor.core.Scannable.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the Attr key, implementors should take care to return values of the correct type, and return null if no specific value is available.

For public consumption of attributes, prefer using scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters

key:Scannable.Attr<T>: a Attr to resolve for the component.

Returns:Object

the value associated to the key for that specific component, or null if none.

Annotations

@Override
@Nullable

sendFirstPayload	back to summary
pack-priv void sendFirstPayload(Payload payload, long initialRequestN)

setFrames	back to summary
public void setFrames(CompositeByteBuf byteBuf) Implements io.rsocket.core.RequesterFrameHandler.setFrames. Annotations @Override

setFrames

back to summary

public void setFrames(CompositeByteBuf byteBuf)

Implements io.rsocket.core.RequesterFrameHandler.setFrames.

Annotations

@Override

stepName back to summary

stepName	back to summary
public String stepName() Overrides default reactor.core.Scannable.stepName. Doc from reactor.core.Scannable.stepName. Return a meaningful `String` representation of this `Scannable` in its chain of `parents()` and `actuals()`. Annotations @Override @NonNull

public String stepName()

Overrides default reactor.core.Scannable.stepName.

Doc from reactor.core.Scannable.stepName.

Return a meaningful String representation of this Scannable in its chain of parents() and actuals().

Annotations

@Override
@NonNull

subscribe back to summary

subscribe	back to summary
public void subscribe(CoreSubscriber<? super Payload> actual) Implements abstract reactor.core.publisher.Flux.subscribe. Implements reactor.core.CorePublisher.subscribe. Doc from reactor.core.publisher.Flux.subscribe. An internal `Publisher#subscribe(Subscriber)` that will bypass `Hooks#onLastOperator(Function)` pointcut. In addition to behave as expected by `Publisher#subscribe(Subscriber)` in a controlled manner, it supports direct subscribe-time `Context` passing. Parameters actual:CoreSubscriber<? super Payload> the `Subscriber` interested into the published sequence Annotations @Override

public void subscribe(CoreSubscriber<? super Payload> actual)

Implements abstract reactor.core.publisher.Flux.subscribe.

Implements reactor.core.CorePublisher.subscribe.

Doc from reactor.core.publisher.Flux.subscribe.

An internal Publisher#subscribe(Subscriber) that will bypass Hooks#onLastOperator(Function) pointcut.

In addition to behave as expected by Publisher#subscribe(Subscriber) in a controlled manner, it supports direct subscribe-time Context passing.

Parameters

actual:CoreSubscriber<? super Payload>: the Subscriber interested into the published sequence

Annotations

@Override

pack-priv final Class RequestStreamRequesterFlux

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail