Package se.fortnox.reactivewizard.jaxrs

Class ByteBufCollector

java.lang.Object

se.fortnox.reactivewizard.jaxrs.ByteBufCollector

public class ByteBufCollector
extends Object

Constructor Summary

Constructors

Constructor	Description
ByteBufCollector()
ByteBufCollector(int maxReqSize)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<byte[]>	collectBytes(reactor.core.publisher.Flux<io.netty.buffer.ByteBuf> content)	Collect bytes from content.
org.reactivestreams.Publisher<byte[]>	collectBytes(reactor.netty.ByteBufFlux input)
reactor.core.publisher.Mono<String>	collectString(reactor.netty.ByteBufFlux input)
rx.Observable<String>	collectString(rx.Observable<io.netty.buffer.ByteBuf> input)	Collect string from input.

Methods inherited from class java.lang.Object

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

Constructor Details

ByteBufCollector

public ByteBufCollector()

ByteBufCollector

public ByteBufCollector(int maxReqSize)

Method Details

collectString

public rx.Observable<String> collectString(rx.Observable<io.netty.buffer.ByteBuf> input)

Collect string from input.

Parameters:

input - the input

Returns:

the string

collectString

public reactor.core.publisher.Mono<String> collectString(reactor.netty.ByteBufFlux input)

collectBytes

public reactor.core.publisher.Mono<byte[]> collectBytes(reactor.core.publisher.Flux<io.netty.buffer.ByteBuf> content)

Collect bytes from content.

Parameters:

content - the content

Returns:

the bytes

collectBytes

public org.reactivestreams.Publisher<byte[]> collectBytes(reactor.netty.ByteBufFlux input)