com.artipie.http.rq

Class PartFromPublisher

java.lang.Object

com.artipie.http.rq.PartFromPublisher

All Implemented Interfaces:

Part, org.reactivestreams.Publisher<ByteBuffer>

public final class PartFromPublisher
extends Object
implements Part

Turn Publisher of bytes into a Part.

Since:

0.7.2

Constructor Summary

Constructors

Constructor and Description
PartFromPublisher(org.reactivestreams.Publisher<ByteBuffer> publisher) Ctor.

Method Summary

Modifier and Type	Method and Description
Iterable<Map.Entry<String,String>>	headers() Part headers.
void	subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> sub)

Methods inherited from class java.lang.Object

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

Constructor Detail

PartFromPublisher

public PartFromPublisher(org.reactivestreams.Publisher<ByteBuffer> publisher)

Ctor.

Parameters:

publisher - The publisher to create part from.

Method Detail

headers

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

Description copied from interface: Part

Part headers.

Specified by:

headers in interface Part

Returns:

Iterable of key-value pairs

subscribe

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

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>