Package kong.unirest.core.java
Class PartSubscriber
- java.lang.Object
-
- kong.unirest.core.java.PartSubscriber
-
- All Implemented Interfaces:
java.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>
class PartSubscriber extends java.lang.Object implements java.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.ConcurrentLinkedQueue<java.nio.ByteBuffer>
buffers
private MultipartSubscription
downstream
(package private) static java.nio.ByteBuffer
END_OF_PART
private ProgressMonitor
monitor
private Part
part
private Prefetcher
prefetcher
private long
total
private Upstream
upstream
-
Constructor Summary
Constructors Constructor Description PartSubscriber(MultipartSubscription downstream, Part part, ProgressMonitor monitor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
abortUpstream(boolean cancel)
Part
getPart()
void
onComplete()
void
onError(java.lang.Throwable throwable)
void
onNext(java.nio.ByteBuffer item)
void
onSubscribe(java.util.concurrent.Flow.Subscription subscription)
(package private) java.nio.ByteBuffer
pollNext()
-
-
-
Field Detail
-
END_OF_PART
static final java.nio.ByteBuffer END_OF_PART
-
downstream
private final MultipartSubscription downstream
-
part
private final Part part
-
monitor
private final ProgressMonitor monitor
-
buffers
private final java.util.concurrent.ConcurrentLinkedQueue<java.nio.ByteBuffer> buffers
-
upstream
private final Upstream upstream
-
prefetcher
private final Prefetcher prefetcher
-
total
private long total
-
-
Constructor Detail
-
PartSubscriber
PartSubscriber(MultipartSubscription downstream, Part part, ProgressMonitor monitor)
-
-
Method Detail
-
onSubscribe
public void onSubscribe(java.util.concurrent.Flow.Subscription subscription)
- Specified by:
onSubscribe
in interfacejava.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>
-
onNext
public void onNext(java.nio.ByteBuffer item)
- Specified by:
onNext
in interfacejava.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>
-
onError
public void onError(java.lang.Throwable throwable)
- Specified by:
onError
in interfacejava.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>
-
onComplete
public void onComplete()
- Specified by:
onComplete
in interfacejava.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>
-
abortUpstream
void abortUpstream(boolean cancel)
-
pollNext
java.nio.ByteBuffer pollNext()
-
getPart
public Part getPart()
-
-