Package kong.unirest.core.java
Class PartSubscriber
java.lang.Object
kong.unirest.core.java.PartSubscriber
- All Implemented Interfaces:
Flow.Subscriber<ByteBuffer>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final ConcurrentLinkedQueue
<ByteBuffer> private final MultipartSubscription
(package private) static final ByteBuffer
private final ProgressMonitor
private final Part
private final Prefetcher
private long
private final Upstream
-
Constructor Summary
ConstructorsConstructorDescriptionPartSubscriber
(MultipartSubscription downstream, Part part, ProgressMonitor monitor) -
Method Summary
Modifier and TypeMethodDescription(package private) void
abortUpstream
(boolean cancel) getPart()
void
void
void
onNext
(ByteBuffer item) void
onSubscribe
(Flow.Subscription subscription) (package private) ByteBuffer
pollNext()
-
Field Details
-
END_OF_PART
-
downstream
-
part
-
monitor
-
buffers
-
upstream
-
prefetcher
-
total
private long total
-
-
Constructor Details
-
PartSubscriber
PartSubscriber(MultipartSubscription downstream, Part part, ProgressMonitor monitor)
-
-
Method Details
-
onSubscribe
- Specified by:
onSubscribe
in interfaceFlow.Subscriber<ByteBuffer>
-
onNext
- Specified by:
onNext
in interfaceFlow.Subscriber<ByteBuffer>
-
onError
- Specified by:
onError
in interfaceFlow.Subscriber<ByteBuffer>
-
onComplete
public void onComplete()- Specified by:
onComplete
in interfaceFlow.Subscriber<ByteBuffer>
-
abortUpstream
void abortUpstream(boolean cancel) -
pollNext
ByteBuffer pollNext() -
getPart
-