コンストラクターの詳細

• PayloadUtils

  public PayloadUtils()

メソッドの詳細

• retainDataAndReleasePayload

  public static DataBuffer retainDataAndReleasePayload(io.rsocket.Payload payload,
                                                       DataBufferFactory bufferFactory)

  このメソッドを使用して、Payload のデータ部分をスライス、保持、ラップし、Payload を解放します。これは、ペイロードメタデータがすでに読み込まれていることを前提とし、ダウンストリームコードは DataBuffer のみを認識する必要があることを保証します。

  パラメーター:

  payload - 処理するペイロード

  bufferFactory - ラップする DataBufferFactory

  戻り値:

  作成された DataBuffer インスタンス

• createPayload

  public static io.rsocket.Payload createPayload(DataBuffer data,
                                                 DataBuffer metadata)

  指定されたメタデータとデータからペイロードを作成します。

  少なくとも 1 つが NettyDataBuffer の場合、ByteBufPayload は、基になるネイティブ ByteBuf を取得するか、必要に応じて Unpooled.wrappedBuffer(ByteBuffer...) を使用して作成されます。それ以外の場合、両方が DefaultDataBuffer であれば、DefaultPayload が作成されます。

  パラメーター:

  data - ペイロードのデータ部分

  metadata - ペイロードのメタデータ部分

  戻り値:

  作成されたペイロード

• createPayload

  public static io.rsocket.Payload createPayload(DataBuffer data)

  データのみでペイロードを作成します。入力が NettyDataBuffer の場合、作成されるペイロードは ByteBufPayload です。それ以外の場合は、DefaultPayload です。

  パラメーター:

  data - ペイロードのデータ部分

  戻り値:

  作成されたペイロード