Package se.fortnox.reactivewizard.jaxrs.response

Class JaxRsStreamingResult<T>

java.lang.Object

se.fortnox.reactivewizard.jaxrs.response.JaxRsResult<T>

se.fortnox.reactivewizard.jaxrs.response.JaxRsStreamingResult<T>

public class JaxRsStreamingResult<T>
extends JaxRsResult<T>

Field Summary

Fields inherited from class se.fortnox.reactivewizard.jaxrs.response.JaxRsResult

EMPTY_RESPONSE, EMPTY_RESPONSE_MONO, headers, output, responseStatus, serializer

Constructor Summary

Constructors

Constructor	Description
JaxRsStreamingResult(reactor.core.publisher.Flux<T> output, io.netty.handler.codec.http.HttpResponseStatus responseStatus, rx.functions.Func1<reactor.core.publisher.Flux<T>,reactor.core.publisher.Flux<byte[]>> serializer, Map<String,String> headers)

Method Summary

Modifier and Type	Method	Description
org.reactivestreams.Publisher<Void>	write(reactor.netty.http.server.HttpServerResponse response)	Write the response.

Methods inherited from class se.fortnox.reactivewizard.jaxrs.response.JaxRsResult

addHeader, doOnOutput, getResponseStatus, map

Methods inherited from class java.lang.Object

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

Constructor Details

JaxRsStreamingResult

public JaxRsStreamingResult(reactor.core.publisher.Flux<T> output,
 io.netty.handler.codec.http.HttpResponseStatus responseStatus,
 rx.functions.Func1<reactor.core.publisher.Flux<T>,reactor.core.publisher.Flux<byte[]>> serializer,
 Map<String,String> headers)

Method Details

write

public org.reactivestreams.Publisher<Void> write(reactor.netty.http.server.HttpServerResponse response)

Description copied from class: JaxRsResult

Write the response.

Overrides:

write in class JaxRsResult<T>

Parameters:

response - the response

Returns:

empty publisher