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

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()

Methods inherited from class java.lang.Object

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

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 interface java.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>

onNext

public void onNext(java.nio.ByteBuffer item)

Specified by:

onNext in interface java.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>

onError

public void onError(java.lang.Throwable throwable)

Specified by:

onError in interface java.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>

onComplete

public void onComplete()

Specified by:

onComplete in interface java.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>

abortUpstream

void abortUpstream(boolean cancel)

pollNext

java.nio.ByteBuffer pollNext()

getPart

public Part getPart()