Package kong.unirest.core.java

Class PartSubscriber

java.lang.Object

kong.unirest.core.java.PartSubscriber

All Implemented Interfaces:

Flow.Subscriber<ByteBuffer>

class PartSubscriber
extends Object
implements Flow.Subscriber<ByteBuffer>

Field Summary

Fields

Modifier and Type	Field	Description
private final ConcurrentLinkedQueue<ByteBuffer>	buffers
private final MultipartSubscription	downstream
(package private) static final ByteBuffer	END_OF_PART
private final ProgressMonitor	monitor
private final Part	part
private final Prefetcher	prefetcher
private long	total
private final Upstream	upstream

Constructor Summary

Constructors

Constructor	Description
PartSubscriber(MultipartSubscription downstream, Part part, ProgressMonitor monitor)

Method Summary

Modifier and Type	Method	Description
(package private) void	abortUpstream(boolean cancel)
Part	getPart()
void	onComplete()
void	onError(Throwable throwable)
void	onNext(ByteBuffer item)
void	onSubscribe(Flow.Subscription subscription)
(package private) ByteBuffer	pollNext()

Methods inherited from class java.lang.Object

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

Field Details

END_OF_PART

static final ByteBuffer END_OF_PART

downstream

private final MultipartSubscription downstream

part

private final Part part

monitor

private final ProgressMonitor monitor

buffers

private final ConcurrentLinkedQueue<ByteBuffer> buffers

upstream

private final Upstream upstream

prefetcher

private final Prefetcher prefetcher

total

private long total

Constructor Details

PartSubscriber

PartSubscriber(MultipartSubscription downstream,
 Part part,
 ProgressMonitor monitor)

Method Details

onSubscribe

public void onSubscribe(Flow.Subscription subscription)

Specified by:

onSubscribe in interface Flow.Subscriber<ByteBuffer>

onNext

public void onNext(ByteBuffer item)

Specified by:

onNext in interface Flow.Subscriber<ByteBuffer>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface Flow.Subscriber<ByteBuffer>

onComplete

public void onComplete()

Specified by:

onComplete in interface Flow.Subscriber<ByteBuffer>

abortUpstream

void abortUpstream(boolean cancel)

pollNext

ByteBuffer pollNext()

getPart

public Part getPart()