public class ServerSentEventHttpMessageWriter extends Object implements HttpMessageWriter<Object>
HttpMessageWriter
for "text/event-stream"
responses.Constructor and Description |
---|
ServerSentEventHttpMessageWriter()
Constructor without an
Encoder . |
ServerSentEventHttpMessageWriter(Encoder<?> encoder)
Constructor with JSON
Encoder for encoding objects. |
Modifier and Type | Method and Description |
---|---|
boolean |
canWrite(ResolvableType elementType,
MediaType mediaType)
Whether the given object type is supported by this writer.
|
Encoder<?> |
getEncoder()
Return the configured
Encoder , if any. |
List<MediaType> |
getWritableMediaTypes()
Return the
MediaType 's that this writer supports. |
reactor.core.publisher.Mono<Void> |
write(org.reactivestreams.Publisher<?> input,
ResolvableType elementType,
MediaType mediaType,
ReactiveHttpOutputMessage message,
Map<String,Object> hints)
Write an given stream of object to the output message.
|
reactor.core.publisher.Mono<Void> |
write(org.reactivestreams.Publisher<?> input,
ResolvableType actualType,
ResolvableType elementType,
MediaType mediaType,
ServerHttpRequest request,
ServerHttpResponse response,
Map<String,Object> hints)
Server-side only alternative to
HttpMessageWriter.write(Publisher, ResolvableType, MediaType, ReactiveHttpOutputMessage, Map)
with additional context available. |
public ServerSentEventHttpMessageWriter()
Encoder
. In this mode only String
is supported for event data to be encoded.public List<MediaType> getWritableMediaTypes()
HttpMessageWriter
MediaType
's that this writer supports.getWritableMediaTypes
in interface HttpMessageWriter<Object>
public boolean canWrite(ResolvableType elementType, @Nullable MediaType mediaType)
HttpMessageWriter
canWrite
in interface HttpMessageWriter<Object>
elementType
- the type of object to checkmediaType
- the media type for the write, possibly null
true
if writable, false
otherwisepublic reactor.core.publisher.Mono<Void> write(org.reactivestreams.Publisher<?> input, ResolvableType elementType, @Nullable MediaType mediaType, ReactiveHttpOutputMessage message, Map<String,Object> hints)
HttpMessageWriter
write
in interface HttpMessageWriter<Object>
input
- the objects to writeelementType
- the type of objects in the stream which must have been
previously checked via HttpMessageWriter.canWrite(ResolvableType, MediaType)
mediaType
- the content type for the write, possibly null
to
indicate that the default content type of the writer must be used.message
- the message to write tohints
- additional information about how to encode and writepublic reactor.core.publisher.Mono<Void> write(org.reactivestreams.Publisher<?> input, ResolvableType actualType, ResolvableType elementType, @Nullable MediaType mediaType, ServerHttpRequest request, ServerHttpResponse response, Map<String,Object> hints)
HttpMessageWriter
HttpMessageWriter.write(Publisher, ResolvableType, MediaType, ReactiveHttpOutputMessage, Map)
with additional context available.write
in interface HttpMessageWriter<Object>
actualType
- the actual return type of the method that returned the
value; for annotated controllers, the MethodParameter
can be
accessed via ResolvableType.getSource()
.elementType
- the type of Objects in the input streammediaType
- the content type to use, possibly null
indicating
the default content type of the writer should be used.request
- the current requestresponse
- the current responseMono
that indicates completion of writing or error