Class Upstream

java.lang.Object

kong.unirest.core.java.Upstream

class Upstream
extends Object

A one-use atomic reference to an upstream subscription.

Field Summary

Fields

Modifier and Type	Field	Description
static final Flow.Subscription	NOOP_SUBSCRIPTION
private Flow.Subscription	subscription
private static final VarHandle	SUBSCRIPTION

Constructor Summary

Constructors

Constructor	Description
Upstream()

Method Summary

Modifier and Type	Method	Description
void	cancel()	Cancels the upstream if set.
void	clear()	Just loses the reference to upstream if cancellation it is not required.
void	request(long n)	Requests n items from upstream if set.
boolean	setOrCancel(Flow.Subscription incoming)	Sets incoming subscription, cancels it if already set.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

NOOP_SUBSCRIPTION

public static final Flow.Subscription NOOP_SUBSCRIPTION

SUBSCRIPTION

private static final VarHandle SUBSCRIPTION

subscription

private volatile Flow.Subscription subscription

Constructor Details

Upstream

public Upstream()

Method Details

setOrCancel

public boolean setOrCancel(Flow.Subscription incoming)

Sets incoming subscription, cancels it if already set.

request

public void request(long n)

Requests n items from upstream if set.

cancel

public void cancel()

Cancels the upstream if set.

clear

public void clear()

Just loses the reference to upstream if cancellation it is not required.