クラス DataBufferUtils

メソッドの詳細

• readInputStream

  public static reactor.core.publisher.Flux<DataBuffer> readInputStream(CallableSE<InputStreamSE> inputStreamSupplier, DataBufferFactory bufferFactory, int bufferSize)

  指定されたサプライヤーから InputStreamSE を取得し、それを DataBuffer の Flux に読み込みます。Flux が終了すると、入力ストリームを閉じます。

  パラメーター:

  inputStreamSupplier - 読み取り元の入力ストリームのサプライヤー

  bufferFactory - データバッファを作成するファクトリ

  bufferSize - データバッファの最大サイズ

  戻り値:

  指定されたチャネルから読み取られた Flux のデータバッファ

• readByteChannel

  public static reactor.core.publisher.Flux<DataBuffer> readByteChannel(CallableSE<ReadableByteChannelSE> channelSupplier, DataBufferFactory bufferFactory, int bufferSize)

  指定されたサプライヤーから ReadableByteChannelSE を取得し、それを DataBuffer の Flux に読み込みます。Flux が終了するとチャネルを閉じます。

  パラメーター:

  channelSupplier - チャンネルの読み取り元のサプライヤー

  bufferFactory - データバッファを作成するファクトリ

  bufferSize - データバッファの最大サイズ

  戻り値:

  指定されたチャネルから読み取られた Flux のデータバッファ

• readAsynchronousFileChannel

  public static reactor.core.publisher.Flux<DataBuffer> readAsynchronousFileChannel(CallableSE<AsynchronousFileChannelSE> channelSupplier, DataBufferFactory bufferFactory, int bufferSize)

  指定されたサプライヤーから AsynchronousFileChannel を取得し、それを DataBuffer の Flux に読み込みます。Flux が終了するとチャネルを閉じます。

  パラメーター:

  channelSupplier - チャンネルの読み取り元のサプライヤー

  bufferFactory - データバッファを作成するファクトリ

  bufferSize - データバッファの最大サイズ

  戻り値:

  指定されたチャネルから読み取られた Flux のデータバッファ

• readAsynchronousFileChannel

  public static reactor.core.publisher.Flux<DataBuffer> readAsynchronousFileChannel(CallableSE<AsynchronousFileChannelSE> channelSupplier, long position, DataBufferFactory bufferFactory, int bufferSize)

  指定されたサプライヤーから AsynchronousFileChannel を取得し、指定された位置から DataBuffer の Flux に読み込みます。Flux が終了するとチャネルを閉じます。

  パラメーター:

  channelSupplier - チャンネルの読み取り元のサプライヤー

  position - 読み取りを開始する位置

  bufferFactory - データバッファを作成するファクトリ

  bufferSize - データバッファの最大サイズ

  戻り値:

  指定されたチャネルから読み取られた Flux のデータバッファ

• read

  public static reactor.core.publisher.Flux<DataBuffer> read(PathSE path, DataBufferFactory bufferFactory, int bufferSize, OpenOptionSE... options)

  指定されたファイル Path から DataBuffer の Flux にバイトを読み取ります。このメソッドは、flux が終了したときにファイルが閉じられることを保証します。

  パラメーター:

  path - バイトを読み取るパス

  bufferFactory - データバッファを作成するファクトリ

  bufferSize - データバッファの最大サイズ

  戻り値:

  指定されたチャネルから読み取られた Flux のデータバッファ

  導入:

  5.2

• read

  public static reactor.core.publisher.Flux<DataBuffer> read(Resource resource, DataBufferFactory bufferFactory, int bufferSize)

  指定された Resource を DataBuffer の Flux に読み取ります。

  リソースがファイルの場合、AsynchronousFileChannel に読み込まれ、readAsynchronousFileChannel(Callable, DataBufferFactory, int) を介して Flux に変換されるか、readByteChannel(Callable, DataBufferFactory, int) にフォールバックします。flux が終了するとチャネルが閉じられます。

  パラメーター:

  resource - 読み取るリソース

  bufferFactory - データバッファを作成するファクトリ

  bufferSize - データバッファの最大サイズ

  戻り値:

  指定されたチャネルから読み取られた Flux のデータバッファ

• read

  public static reactor.core.publisher.Flux<DataBuffer> read(Resource resource, long position, DataBufferFactory bufferFactory, int bufferSize)

  指定された Resource を、指定された位置から DataBuffer の Flux に読み込みます。

  リソースがファイルの場合、AsynchronousFileChannel に読み込まれ、readAsynchronousFileChannel(Callable, DataBufferFactory, int) を介して Flux に変換されるか、readByteChannel(Callable, DataBufferFactory, int) にフォールバックします。flux が終了するとチャネルが閉じられます。

  パラメーター:

  resource - 読み取るリソース

  position - 読み取りを開始する位置

  bufferFactory - データバッファを作成するファクトリ

  bufferSize - データバッファの最大サイズ

  戻り値:

  指定されたチャネルから読み取られた Flux のデータバッファ

• write

  public static reactor.core.publisher.Flux<DataBuffer> write(Publisher<DataBuffer> source, OutputStreamSE outputStream)

  指定された DataBuffers のストリームを指定された OutputStream に書き込みます。flux が終了しても出力ストリームは閉じられず、ソース内のデータバッファーは解放されません。解放が必要な場合は、返された Flux に releaseConsumer() でサブスクライブします。

  返された Flux がサブスクライブされるまで、書き込みプロセスは開始されないことに注意してください。

  パラメーター:

  source - 書き込まれるデータバッファのストリーム

  outputStream - 書き込む出力ストリーム

  戻り値:

  source と同じバッファを含む Flux。サブスクライブされると書き込みプロセスを開始し、書き込みエラーと完了シグナルを発行します。

• write

  public static reactor.core.publisher.Flux<DataBuffer> write(Publisher<DataBuffer> source, WritableByteChannelSE channel)

  指定された DataBuffers のストリームを指定された WritableByteChannel に書き込みます。flux が終了してもチャネルは閉じられず、ソース内のデータバッファーは解放されません。解放が必要な場合は、返された Flux に releaseConsumer() でサブスクライブします。

  返された Flux がサブスクライブされるまで、書き込みプロセスは開始されないことに注意してください。

  パラメーター:

  source - 書き込まれるデータバッファのストリーム

  channel - 書き込むチャネル

  戻り値:

  source と同じバッファを含む Flux。サブスクライブされると書き込みプロセスを開始し、書き込みエラーと完了シグナルを発行します。

• write

  public static reactor.core.publisher.Flux<DataBuffer> write(Publisher<DataBuffer> source, AsynchronousFileChannelSE channel)

  指定された DataBuffers のストリームを指定された AsynchronousFileChannel に書き込みます。flux が終了してもチャネルは閉じられず、ソース内のデータバッファーは解放されません。解放が必要な場合は、返された Flux に releaseConsumer() でサブスクライブします。

  返された Flux がサブスクライブされるまで、書き込みプロセスは開始されないことに注意してください。

  パラメーター:

  source - 書き込まれるデータバッファのストリーム

  channel - 書き込むチャネル

  戻り値:

  source と同じバッファを含む Flux。サブスクライブされると書き込みプロセスを開始し、書き込みエラーと完了シグナルを発行します。

  導入:

  5.0.10

• write

  public static reactor.core.publisher.Flux<DataBuffer> write(Publisher<? extends DataBuffer> source, AsynchronousFileChannelSE channel, long position)

  指定された DataBuffers のストリームを指定された AsynchronousFileChannel に書き込みます。flux が終了してもチャネルは閉じられず、ソース内のデータバッファーは解放されません。解放が必要な場合は、返された Flux に releaseConsumer() でサブスクライブします。

  返された Flux がサブスクライブされるまで、書き込みプロセスは開始されないことに注意してください。

  パラメーター:

  source - 書き込まれるデータバッファのストリーム

  channel - 書き込むチャネル

  position - 書き込みを開始するファイルの位置。負でない必要があります

  戻り値:

  source と同じバッファを含む flux。サブスクライブされると書き込みプロセスを開始し、書き込みエラーと完了シグナルを発行します。

• write

  public static reactor.core.publisher.Mono<VoidSE> write(Publisher<DataBuffer> source, PathSE destination, OpenOptionSE... options)

  DataBuffers の指定されたストリームを指定されたファイル PathSE に書き込みます。オプションの options パラメーターは、ファイルの作成方法またはオープン方法を指定します（デフォルトは CREATESE、TRUNCATE_EXISTINGSE、WRITESE）。

  パラメーター:

  source - 書き込まれるデータバッファのストリーム

  destination - ファイルへのパス

  options - ファイルを開く方法を指定するオプション

  戻り値:

  完了またはエラーを示す Mono 

  導入:

  5.2

• outputStreamPublisher

  public static Publisher<DataBuffer> outputStreamPublisher(ConsumerSE<OutputStreamSE> consumer, DataBufferFactory bufferFactory, ExecutorSE executor)

  OutputStream に書き込まれたバイトに基づいて、新しい Publisher<DataBuffer> を作成します。

  • パラメーター outputStreamConsumer は、最初の項目がリクエストされたときに、返された Publisher のサブスクリプションごとに 1 回呼び出されます。
  • outputStreamConsumer によって行われた OutputStream.write()SE 呼び出しは、デフォルトのチャンクサイズ 1024 を超えるまで、またはストリームがフラッシュされるまでバッファーされ、リクエストがある場合はアイテムが公開されます。
  • 要求がない場合、OutputStream.write() は要求があるまでブロックします。
  • サブスクリプションがキャンセルされた場合、OutputStream.write() は IOException をスローします。
  • outputStreamHandler が完了すると、サブスクリプションが完了します。
  • outputStreamHandler からスローされた例外はすべて、サブスクライバーにディスパッチされます。

  パラメーター:

  consumer - 最初のバッファがリクエストされたときに呼び出されます

  executor - outputStreamHandler を呼び出すために使用されます

  戻り値:

  outputStreamHandler によって書き込まれたバイトに基づく Publisher<DataBuffer> 

  導入:

  6.1

• outputStreamPublisher

  public static Publisher<DataBuffer> outputStreamPublisher(ConsumerSE<OutputStreamSE> consumer, DataBufferFactory bufferFactory, ExecutorSE executor, int chunkSize)

  パブリッシャーによって生成されるチャンクサイズを制御する outputStreamPublisher(Consumer, DataBufferFactory, Executor) のバリアント。

  導入:

  6.1

• subscriberInputStream

  public static <T extends DataBuffer> InputStreamSE subscriberInputStream(Publisher<T> publisher, int demand)

  指定された DataBuffer の Publisher をサブスクライブし、バイトコンテンツを消費するための InputStreamSE を返します。

  バイトバッファはキューに格納されます。demand コンストラクター値によって、最初にリクエストされるバッファの数が決まります。ストレージが (demand - (demand >> 2)) 制限を下回ると、キューを補充するリクエストが行われます。

  InputStream は onError または onComplete シグナルの後に終了し、保存されたバッファが読み取られます。InputStream が閉じられると、Flow.SubscriptionSE はキャンセルされ、保存されたバッファが解放されます。

  パラメーター:

  publisher - DataBuffer のソース

  demand - 最初にリクエストするバッファの数と、継続的に内部的にバッファリングするバッファの数。

  戻り値:

  Publisher による InputStreamSE

• takeUntilByteCount

  public static <T extends DataBuffer> reactor.core.publisher.Flux<T> takeUntilByteCount(Publisher<T> publisher, long maxByteCount)

  合計バイト数が指定された最大バイト数に達するまで、またはパブリッシャーが完了するまで、指定された Publisher からバッファーをリレーします。

  パラメーター:

  publisher - フィルタリングするパブリッシャー

  maxByteCount - 最大バイト数

  戻り値:

  最大バイト数が maxByteCount である flux

• skipUntilByteCount

  public static <T extends DataBuffer> reactor.core.publisher.Flux<T> skipUntilByteCount(Publisher<T> publisher, long maxByteCount)

  合計バイト数が指定された最大バイト数に達するまで、またはパブリッシャーが完了するまで、指定された Publisher からバッファーをスキップします。

  パラメーター:

  publisher - フィルタリングするパブリッシャー

  maxByteCount - 最大バイト数

  戻り値:

  指定された発行者の残りの部分を含む flux

• retain

  public static <T extends DataBuffer> T retain(T dataBuffer)

  PooledDataBuffer の場合、指定されたデータバッファを保持します。

  パラメーター:

  dataBuffer - 保持するデータバッファ

  戻り値:

  保存バッファ

• touch

  public static <T extends DataBuffer> T touch(T dataBuffer, ObjectSE hint)

  指定されたヒントがプールされたバッファであり、リークトラッキングをサポートしている場合は、データバッファに関連付けます。

  パラメーター:

  dataBuffer - ヒントを添付するデータバッファ

  hint - 添付するヒント

  戻り値:

  入力バッファ

  導入:

  5.3.2

• release

  public static boolean release(@Nullable DataBuffer dataBuffer)

  指定されたデータバッファーを解放します。それが PooledDataBuffer であり、割り当てられている場合、このメソッドは PooledDataBuffer.release() を呼び出します。CloseableDataBuffer の場合、このメソッドは CloseableDataBuffer.close() を呼び出します。

  パラメーター:

  dataBuffer - 解放するデータバッファ

  戻り値:

  バッファが解放された場合は true。それ以外の場合は false。

• releaseConsumer

  public static ConsumerSE<DataBuffer> releaseConsumer()

  渡されたすべてのデータバッファで release(DataBuffer) を呼び出すコンシューマーを返します。

• join

  public static reactor.core.publisher.Mono<DataBuffer> join(Publisher<? extends DataBuffer> dataBuffers)

  指定された dataBuffers 要素を結合して構成される新しい DataBuffer を返します。DataBuffer 型に応じて、返されるバッファーは、提供されたバッファーのすべてのデータを含む単一のバッファーである場合もあれば、指定されたバッファーへの参照を含むゼロコピーの複合である場合もあります。

  dataBuffers でエラーが発生した場合、またはキャンセルシグナルが発生した場合は、蓄積されたすべてのバッファが解放されます。

  指定されたデータバッファを解放する必要がないことに注意してください。それらは、返却されたコンポジットの一部としてリリースされます。

  パラメーター:

  dataBuffers - 構成されるデータバッファ

  戻り値:

  dataBuffers 引数で構成されるバッファー

  導入:

  5.0.3

• join

  public static reactor.core.publisher.Mono<DataBuffer> join(Publisher<? extends DataBuffer> buffers, int maxByteCount)

  バッファリングする指定された最大バイト数まで同じように動作する join(Publisher) のバリアント。制限を超えると、DataBufferLimitException が発生します。

  パラメーター:

  buffers - 構成されるデータバッファ

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

  戻り値:

  集約されたコンテンツを含むバッファ。バッファする最大バイト数を超える場合は空の Mono。

  例外:

  DataBufferLimitException - maxByteCount を超えた場合

  導入:

  5.1.11

• matcher

  public static DataBufferUtils.Matcher matcher(byte[] delimiter)

  指定された区切り文字の DataBufferUtils.Matcher を返します。マッチャーは、データバッファーのストリーム内の区切り文字を見つけるために使用できます。

  パラメーター:

  delimiter - 検索する区切り文字バイト

  戻り値:

  マッチャー

  導入:

  5.2

• matcher

  public static DataBufferUtils.Matcher matcher(byte[]... delimiters)

  指定された区切り文字の DataBufferUtils.Matcher を返します。マッチャーは、データバッファーのストリーム内の区切り文字を見つけるために使用できます。

  パラメーター:

  delimiters - 検索する区切り文字バイト

  戻り値:

  マッチャー

  導入:

  5.2