Package kong.unirest.core.java
Class Upstream
- java.lang.Object
-
- kong.unirest.core.java.Upstream
-
class Upstream extends java.lang.Object
A one-use atomic reference to an upstream subscription.
-
-
Field Summary
Fields Modifier and Type Field Description static java.util.concurrent.Flow.Subscription
NOOP_SUBSCRIPTION
private java.util.concurrent.Flow.Subscription
subscription
private static java.lang.invoke.VarHandle
SUBSCRIPTION
-
Constructor Summary
Constructors Constructor Description Upstream()
-
Method Summary
All Methods Instance Methods Concrete Methods 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)
Requestsn
items from upstream if set.boolean
setOrCancel(java.util.concurrent.Flow.Subscription incoming)
Sets incoming subscription, cancels it if already set.
-
-
-
Method Detail
-
setOrCancel
public boolean setOrCancel(java.util.concurrent.Flow.Subscription incoming)
Sets incoming subscription, cancels it if already set.
-
request
public void request(long n)
Requestsn
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.
-
-