类 ServerSentEventHttpMessageReader

构造器详细资料

• ServerSentEventHttpMessageReader

  public ServerSentEventHttpMessageReader()

  Constructor without a Decoder. In this mode only String is supported as the data of an event.

• ServerSentEventHttpMessageReader

  public ServerSentEventHttpMessageReader​(@Nullable
                                          Decoder<?> decoder)

  Constructor with JSON Decoder for decoding to Objects. Support for decoding to String event data is built-in.

方法详细资料

• getDecoder

  @Nullable
  public Decoder<?> getDecoder()

  Return the configured Decoder.

• setMaxInMemorySize

  public void setMaxInMemorySize​(int byteCount)

  Configure a limit on the maximum number of bytes per SSE event which are buffered before the event is parsed.

  Note that the data decoder, if provided, must also be customized accordingly to raise the limit if necessary in order to be able to parse the data portion of the event.

  By default this is set to 256K.

  参数:

  byteCount - the max number of bytes to buffer, or -1 for unlimited

  从以下版本开始:

  5.1.13

• getMaxInMemorySize

  public int getMaxInMemorySize()

  Return the configured byte count limit.

  从以下版本开始:

  5.1.13

• getReadableMediaTypes

  public List<MediaType> getReadableMediaTypes()

  从接口复制的说明: HttpMessageReader
  Return the MediaType's that this reader supports.

  指定者:

  getReadableMediaTypes 在接口中 HttpMessageReader<Object>

• canRead

  public boolean canRead​(ResolvableType elementType,
                         @Nullable
                         MediaType mediaType)

  从接口复制的说明: HttpMessageReader
  Whether the given object type is supported by this reader.

  指定者:

  canRead 在接口中 HttpMessageReader<Object>

  参数:

  elementType - the type of object to check

  mediaType - the media type for the read (possibly null)

  返回:

  true if readable, false otherwise

• read

  public reactor.core.publisher.Flux<Object> read​(ResolvableType elementType,
                                                  ReactiveHttpInputMessage message,
                                                  Map<String,​Object> hints)

  从接口复制的说明: HttpMessageReader
  Read from the input message and encode to a stream of objects.

  指定者:

  read 在接口中 HttpMessageReader<Object>

  参数:

  elementType - the type of objects in the stream which must have been previously checked via HttpMessageReader.canRead(ResolvableType, MediaType)

  message - the message to read from

  hints - additional information about how to read and decode the input

  返回:

  the decoded stream of elements

• readMono

  public reactor.core.publisher.Mono<Object> readMono​(ResolvableType elementType,
                                                      ReactiveHttpInputMessage message,
                                                      Map<String,​Object> hints)

  从接口复制的说明: HttpMessageReader
  Read from the input message and encode to a single object.

  指定者:

  readMono 在接口中 HttpMessageReader<Object>

  参数:

  elementType - the type of objects in the stream which must have been previously checked via HttpMessageReader.canRead(ResolvableType, MediaType)

  message - the message to read from

  hints - additional information about how to read and decode the input

  返回:

  the decoded object