コンストラクターの詳細

• ServerSentEventHttpMessageReader

  public ServerSentEventHttpMessageReader()

  Decoder なしのコンストラクター。このモードでは、イベントのデータとして String のみがサポートされています。

• ServerSentEventHttpMessageReader

  public ServerSentEventHttpMessageReader(@Nullable
                                          Decoder<?> decoder)

  オブジェクトにデコードするための JSON Decoder を持つコンストラクター。String イベントデータへのデコードのサポートが組み込まれています。

メソッドの詳細

• getDecoder

  @Nullable
  public Decoder<?> getDecoder()

  設定された Decoder を返します。

• setMaxInMemorySize

  public void setMaxInMemorySize(int byteCount)

  イベントが解析される前にバッファリングされる SSE イベントごとの最大バイト数の制限を構成します。

  data decoder が提供されている場合は、イベントのデータ部分を解析できるようにするために、必要に応じて制限を上げるようにカスタマイズする必要があることに注意してください。

  デフォルトでは、これは 256K に設定されています。

  パラメーター:

  byteCount - バッファリングする最大バイト数、または無制限の場合は -1

  導入:

  5.1.13

• getMaxInMemorySize

  public int getMaxInMemorySize()

  configured バイトカウント制限を返します。

  導入:

  5.1.13

• getReadableMediaTypes

  public ListSE<MediaType> getReadableMediaTypes()

  インターフェースからコピーされた説明: HttpMessageReader
  このリーダーがサポートする MediaType を返します。

  次で指定:

  インターフェース HttpMessageReader<ObjectSE> の getReadableMediaTypes 

• canRead

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

  インターフェースからコピーされた説明: HttpMessageReader
  指定されたオブジェクト型がこのリーダーでサポートされているかどうか。

  次で指定:

  インターフェース HttpMessageReader<ObjectSE> の canRead 

  パラメーター:

  elementType - チェックするオブジェクトの型

  mediaType - 読み取り用のメディア型 (おそらく null)

  戻り値:

  読み取り可能な場合は true、そうでない場合は false 

• read

  public reactor.core.publisher.Flux<ObjectSE> read(ResolvableType elementType,
                                                  ReactiveHttpInputMessage message,
                                                  MapSE<StringSE,ObjectSE> hints)

  インターフェースからコピーされた説明: HttpMessageReader
  入力メッセージから読み取り、オブジェクトのストリームにエンコードします。

  次で指定:

  インターフェース HttpMessageReader<ObjectSE> の read 

  パラメーター:

  elementType - HttpMessageReader.canRead(ResolvableType, MediaType) を介して事前にチェックされている必要があるストリーム内のオブジェクトの型

  message - 読み取るメッセージ

  hints - 入力の読み取りおよびデコード方法に関する追加情報

  戻り値:

  要素のデコードされたストリーム

• readMono

  public reactor.core.publisher.Mono<ObjectSE> readMono(ResolvableType elementType,
                                                      ReactiveHttpInputMessage message,
                                                      MapSE<StringSE,ObjectSE> hints)

  インターフェースからコピーされた説明: HttpMessageReader
  入力メッセージから読み取り、単一のオブジェクトにエンコードします。

  次で指定:

  インターフェース HttpMessageReader<ObjectSE> の readMono 

  パラメーター:

  elementType - HttpMessageReader.canRead(ResolvableType, MediaType) を介して事前にチェックされている必要があるストリーム内のオブジェクトの型

  message - 読み取るメッセージ

  hints - 入力の読み取りおよびデコード方法に関する追加情報

  戻り値:

  デコードされたオブジェクト