Module io.helidon.media.multipart

Package io.helidon.media.multipart

Class MultiPartEncoder

java.lang.Object

io.helidon.media.multipart.MultiPartEncoder

All Implemented Interfaces:

Flow.Processor<WriteableBodyPart,DataChunk>, Flow.Publisher<DataChunk>, Flow.Subscriber<WriteableBodyPart>

public class MultiPartEncoder
extends Object
implements Flow.Processor<WriteableBodyPart,DataChunk>

Reactive processor that encodes a stream of BodyPart into an HTTP payload.

Method Summary

Modifier and Type	Method	Description
static MultiPartEncoder	create(String boundary, MessageBodyWriterContext context)	Create a multipart encoder.
void	onComplete()
void	onError(Throwable throwable)
void	onNext(WriteableBodyPart bodyPart)
void	onSubscribe(Flow.Subscription subscription)
void	subscribe(Flow.Subscriber<? super DataChunk> subscriber)

Methods inherited from class java.lang.Object

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

Method Details

create

public static MultiPartEncoder create(String boundary,
 MessageBodyWriterContext context)

Create a multipart encoder.

Parameters:

boundary - boundary delimiter

context - writer context

Returns:

MultiPartEncoder

subscribe

public void subscribe(Flow.Subscriber<? super DataChunk> subscriber)

Specified by:

subscribe in interface Flow.Publisher<DataChunk>

onSubscribe

public void onSubscribe(Flow.Subscription subscription)

Specified by:

onSubscribe in interface Flow.Subscriber<WriteableBodyPart>

onNext

public void onNext(WriteableBodyPart bodyPart)

Specified by:

onNext in interface Flow.Subscriber<WriteableBodyPart>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface Flow.Subscriber<WriteableBodyPart>

onComplete

public void onComplete()

Specified by:

onComplete in interface Flow.Subscriber<WriteableBodyPart>