com.artipie.http.rq

Class Multipart

java.lang.Object

com.artipie.http.rq.Multipart

All Implemented Interfaces:

org.reactivestreams.Processor<ByteBuffer,Part>, org.reactivestreams.Publisher<Part>, org.reactivestreams.Subscriber<ByteBuffer>

public final class Multipart
extends Object
implements org.reactivestreams.Processor<ByteBuffer,Part>

A multipart parser. Parses a Flow of Bytes into a flow of Multiparts See rfc1341 spec.

Since:

0.4

Constructor Summary

Constructors

Constructor and Description
Multipart(Iterable<Map.Entry<String,String>> headers) Ctor.
Multipart(org.reactivestreams.Processor<ByteBuffer,org.reactivestreams.Publisher<ByteBuffer>> processor) Ctor.
Multipart(String boundary) Ctor.
Multipart(Supplier<String> boundary) Ctor.

Method Summary

Modifier and Type	Method and Description
void	onComplete()
void	onError(Throwable throwable)
void	onNext(ByteBuffer item)
void	onSubscribe(org.reactivestreams.Subscription subscription)
void	subscribe(org.reactivestreams.Subscriber<? super Part> sub)

Methods inherited from class java.lang.Object

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

Constructor Detail

Multipart

public Multipart(Iterable<Map.Entry<String,String>> headers)

Ctor.

Parameters:

headers - Request headers.

Multipart

public Multipart(Supplier<String> boundary)

Ctor.

Parameters:

boundary - The boundary supplier.

Multipart

public Multipart(String boundary)

Ctor.

Parameters:

boundary - Multipart body boundary

Multipart

public Multipart(org.reactivestreams.Processor<ByteBuffer,org.reactivestreams.Publisher<ByteBuffer>> processor)

Ctor.

Parameters:

processor - The processor.

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super Part> sub)

Specified by:

subscribe in interface org.reactivestreams.Publisher<Part>

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription subscription)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<ByteBuffer>

onNext

public void onNext(ByteBuffer item)

Specified by:

onNext in interface org.reactivestreams.Subscriber<ByteBuffer>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface org.reactivestreams.Subscriber<ByteBuffer>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<ByteBuffer>