インターフェースの使用
org.springframework.core.io.buffer.DataBuffer
パッケージ
説明
バイトバッファの実装を操作するための一般的な抽象化。
クライアント / サーバー側 HTTP の基本的な抽象化が含まれています。
CBOR エンコーダーとデコーダーのサポート。
JSON エンコーダーおよびデコーダーのサポート。
マルチパートのサポート。
Google プロトコルバッファのエンコーダーとデコーダーを提供します。
XML エンコーダーおよびデコーダーのサポート。
ノンブロッキング、リアクティブ契約でメッセージハンドラーメソッドを呼び出すための共通インフラストラクチャ。
RSocket プロトコルのサポート。
アノテーション付き RSocket ストリーム処理メソッドを操作するためのクラスをサポートします。
リアクティブ HTTP クライアント契約のモック実装。
リアクティブ HTTP サーバー契約のモック実装。
リアクティブクライアントとサーバーサブパッケージの両方の基盤を提供します。
org.springframework.http.client.reactive
リアクティブ HTTP アダプター層上に構築されるリアクティブ WebClient
を提供します。Spring のリアクティブ環境用の関数 Web フレームワークを構成する型を提供します。
リアクティブ WebSocket 相互作用の抽象化とサポートクラス。
Spring の Reactive WebSocket API を WebSocket ランタイムとの間で適合させるクラス。
org.springframework.core.codec 内の DataBuffer 使用
修飾子と型メソッド説明DataBufferDecoder.decode
(DataBuffer buffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) ByteArrayEncoder.encodeValue
(byte[] bytes, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) ByteBufferEncoder.encodeValue
(ByteBufferSE byteBuffer, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) CharSequenceEncoder.encodeValue
(CharSequenceSE charSequence, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) DataBufferEncoder.encodeValue
(DataBuffer buffer, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) default DataBuffer
Encoder.encodeValue
(T value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 型 T のオブジェクトをデータバッファにエンコードします。Netty5BufferEncoder.encodeValue
(io.netty5.buffer.Buffer buffer, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) NettyByteBufEncoder.encodeValue
(io.netty.buffer.ByteBuf byteBuf, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明reactor.core.publisher.Flux<DataBuffer>
DataBufferDecoder.decode
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) final reactor.core.publisher.Flux<DataBuffer>
AbstractSingleValueEncoder.encode
(Publisher<? extends T> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) protected abstract reactor.core.publisher.Flux<DataBuffer>
AbstractSingleValueEncoder.encode
(T t, DataBufferFactory dataBufferFactory, ResolvableType type, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) T
を出力DataBuffer
ストリームにエンコードします。reactor.core.publisher.Flux<DataBuffer>
ByteArrayEncoder.encode
(Publisher<? extends byte[]> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Flux<DataBuffer>
ByteBufferEncoder.encode
(Publisher<? extends ByteBufferSE> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Flux<DataBuffer>
CharSequenceEncoder.encode
(Publisher<? extends CharSequenceSE> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Flux<DataBuffer>
DataBufferEncoder.encode
(Publisher<? extends DataBuffer> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Flux<DataBuffer>
Encoder.encode
(Publisher<? extends T> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 型T
のオブジェクトのストリームをDataBuffer
出力ストリームにエンコードします。reactor.core.publisher.Flux<DataBuffer>
Netty5BufferEncoder.encode
(Publisher<? extends io.netty5.buffer.Buffer> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Flux<DataBuffer>
NettyByteBufEncoder.encode
(Publisher<? extends io.netty.buffer.ByteBuf> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) protected reactor.core.publisher.Flux<DataBuffer>
ResourceEncoder.encode
(Resource resource, DataBufferFactory bufferFactory, ResolvableType type, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Flux<DataBuffer>
ResourceRegionEncoder.encode
(Publisher<? extends ResourceRegion> input, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明final T
AbstractCharSequenceDecoder.decode
(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) byte[]
ByteArrayDecoder.decode
(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) ByteBufferDecoder.decode
(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) DataBufferDecoder.decode
(DataBuffer buffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) default T
Decoder.decode
(DataBuffer buffer, ResolvableType targetType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) データバッファを型 T のオブジェクトにデコードします。io.netty5.buffer.Buffer
Netty5BufferDecoder.decode
(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) io.netty.buffer.ByteBuf
NettyByteBufDecoder.decode
(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) ResourceDecoder.decode
(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) protected T
AbstractDataBufferDecoder.decodeDataBuffer
(DataBuffer buffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 使用すべきではありません。protected abstract T
AbstractCharSequenceDecoder.decodeInternal
(DataBuffer dataBuffer, CharsetSE charset) 指定された文字セットを使用して、指定されたデータバッファーをT
にデコードするテンプレートメソッド。protected CharBufferSE
CharBufferDecoder.decodeInternal
(DataBuffer dataBuffer, CharsetSE charset) protected StringSE
StringDecoder.decodeInternal
(DataBuffer dataBuffer, CharsetSE charset) DataBufferEncoder.encodeValue
(DataBuffer buffer, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) static void
Hints.touchDataBuffer
(DataBuffer buffer, MapSE<StringSE, ObjectSE> hints, Log logger) ヒントにHints.LOG_PREFIX_HINT
が含まれていて、指定されたロガーで DEBUG レベルが有効になっている場合は、ログプレフィックスをヒントとしてDataBufferUtils.touch(DataBuffer, Object)
を介して指定されたバッファーに適用します。修飾子と型メソッド説明final reactor.core.publisher.Flux<T>
AbstractCharSequenceDecoder.decode
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Flux<T>
AbstractDataBufferDecoder.decode
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Flux<DataBuffer>
DataBufferDecoder.decode
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Flux<T>
Decoder.decode
(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) DataBuffer
入力ストリームをT
の Flux にデコードします。reactor.core.publisher.Flux<Resource>
ResourceDecoder.decode
(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Mono<T>
AbstractDataBufferDecoder.decodeToMono
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Mono<T>
AbstractDecoder.decodeToMono
(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Mono<T>
Decoder.decodeToMono
(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) DataBuffer
入力ストリームをT
の Mono にデコードします。reactor.core.publisher.Flux<DataBuffer>
DataBufferEncoder.encode
(Publisher<? extends DataBuffer> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) org.springframework.core.io.buffer 内の DataBuffer 使用
修飾子と型インターフェース説明interface
try
-with-resources ステートメントで使用できるバッファーを可能にするDataBuffer
の拡張。interface
メモリプールを共有するバッファーを可能にするDataBuffer
の拡張。interface
デバッグ目的でヒントを与えることができるバッファを可能にするDataBuffer
の拡張。修飾子と型クラス説明class
デリゲートを適合させるためにオーバーライドできるDataBuffer
インターフェースの便利な実装を提供します。class
内部でByteBuffer
SE を使用するDataBuffer
インターフェースのデフォルト実装。final class
Netty 5Buffer
をラップするDataBuffer
インターフェースの実装。class
Netty 4ByteBuf
をラップするDataBuffer
インターフェースの実装。修飾子と型メソッド説明static <T extends DataBuffer>
TDataBufferUtils.retain
(T dataBuffer) PooledDataBuffer
の場合、指定されたデータバッファを保持します。static <T extends DataBuffer>
reactor.core.publisher.Flux<T>DataBufferUtils.skipUntilByteCount
(Publisher<T> publisher, long maxByteCount) static <T extends DataBuffer>
reactor.core.publisher.Flux<T>DataBufferUtils.takeUntilByteCount
(Publisher<T> publisher, long maxByteCount) static <T extends DataBuffer>
T指定されたヒントがプールされたバッファであり、リークトラッキングをサポートしている場合は、データバッファに関連付けます。修飾子と型メソッド説明DataBufferFactory.allocateBuffer()
使用すべきではありません。6.0 現在、DataBufferFactory.allocateBuffer(int)
を推奨DataBufferFactory.allocateBuffer
(int initialCapacity) 指定された初期容量のデータバッファーを割り当てます。DataBuffer.capacity
(int capacity) 使用すべきではありません。6.0 の時点で、異なるセマンティクスを持つensureWritable(int)
を優先DataBufferWrapper.capacity
(int capacity) 使用すべきではありません。DefaultDataBuffer.capacity
(int capacity) 使用すべきではありません。DataBufferWrapper.dataBuffer()
ラップされたデリゲートを返します。default DataBuffer
DataBuffer.ensureCapacity
(int capacity) 使用すべきではありません。6.0 以降、ensureWritable(int)
を推奨DataBufferWrapper.ensureCapacity
(int capacity) 使用すべきではありません。DataBuffer.ensureWritable
(int capacity) 現在のバッファーに、引数として指定されたデータ量を書き込むのに十分なwritableByteCount()
があることを確認してください。DataBufferWrapper.ensureWritable
(int capacity) DefaultDataBuffer.ensureWritable
(int length) Netty5DataBuffer.ensureWritable
(int capacity) NettyDataBuffer.ensureWritable
(int capacity) DataBufferFactory.join
(ListSE<? extends DataBuffer> dataBuffers) 一緒に結合されたdataBuffers
要素で構成される新しいDataBuffer
を返します。Netty5DataBufferFactory.join
(ListSE<? extends DataBuffer> dataBuffers) 一緒に結合されたdataBuffers
要素で構成される新しいDataBuffer
を返します。NettyDataBufferFactory.join
(ListSE<? extends DataBuffer> dataBuffers) 一緒に結合されたdataBuffers
要素で構成される新しいDataBuffer
を返します。DataBuffer.read
(byte[] destination) このバッファの現在の読み取り位置から開始して、指定された宛先にこのバッファのデータを読み取ります。DataBuffer.read
(byte[] destination, int offset, int length) このバッファーの現在の読み取り位置から開始して、指定された宛先にこのバッファーの最大length
バイトを読み取ります。DataBufferWrapper.read
(byte[] destination) DataBufferWrapper.read
(byte[] destination, int offset, int length) DataBuffer.readPosition
(int readPosition) このバッファが読み込む位置を設定します。DataBufferWrapper.readPosition
(int readPosition) LimitedDataBufferList.remove
(int index) default DataBuffer
DataBuffer.retainedSlice
(int index, int length) 使用すべきではありません。6.0 の時点で、異なるセマンティクスを持つsplit(int)
を優先DataBufferWrapper.retainedSlice
(int index, int length) 使用すべきではありません。LimitedDataBufferList.set
(int index, DataBuffer element) DataBuffer.slice
(int index, int length) 使用すべきではありません。6.0 の時点で、異なるセマンティクスを持つsplit(int)
を優先DataBufferWrapper.slice
(int index, int length) 使用すべきではありません。Netty5DataBuffer.slice
(int index, int length) 使用すべきではありません。DataBuffer.split
(int index) このデータバッファーを指定されたインデックスで 2 つに分割します。DataBufferWrapper.split
(int index) DefaultDataBuffer.split
(int index) Netty5DataBuffer.split
(int index) DataBufferFactory.wrap
(byte[] bytes) 指定されたbyte
配列をDataBuffer
でラップします。DataBufferFactory.wrap
(ByteBufferSE byteBuffer) 指定されたByteBuffer
SE をDataBuffer
でラップします。NettyDataBufferFactory.wrap
(byte[] bytes) DataBuffer.write
(byte b) このバッファの現在の書き込み位置に 1 バイトを書き込みます。DataBuffer.write
(byte[] source) このバッファの現在の書き込み位置から開始して、指定されたソースをこのバッファに書き込みます。DataBuffer.write
(byte[] source, int offset, int length) このバッファの現在の書き込み位置から開始して、指定されたソースの最大length
バイトをこのバッファに書き込みます。default DataBuffer
DataBuffer.write
(CharSequenceSE charSequence, CharsetSE charset) 現在の書き込み位置から、指定されたCharset
を使用して、指定されたCharSequence
を書き込みます。DataBuffer.write
(ByteBufferSE... buffers) 現在の書き込み位置から開始して、このバッファーに 1 つ以上のByteBuffer
SE を書き込みます。DataBuffer.write
(DataBuffer... buffers) 現在の書き込み位置から開始して、このバッファーに 1 つ以上のDataBuffer
を書き込みます。DataBufferWrapper.write
(byte b) DataBufferWrapper.write
(byte[] source) DataBufferWrapper.write
(byte[] source, int offset, int length) DataBufferWrapper.write
(CharSequenceSE charSequence, CharsetSE charset) DataBufferWrapper.write
(ByteBufferSE... buffers) DataBufferWrapper.write
(DataBuffer... buffers) Netty5DataBuffer.write
(CharSequenceSE charSequence, CharsetSE charset) NettyDataBuffer.write
(CharSequenceSE charSequence, CharsetSE charset) DataBuffer.writePosition
(int writePosition) このバッファが書き込む位置を設定します。DataBufferWrapper.writePosition
(int writePosition) 修飾子と型メソッド説明static reactor.core.publisher.Mono<DataBuffer>
DataBufferUtils.join
(Publisher<? extends DataBuffer> dataBuffers) 指定されたdataBuffers
要素を結合して構成される新しいDataBuffer
を返します。static reactor.core.publisher.Mono<DataBuffer>
DataBufferUtils.join
(Publisher<? extends DataBuffer> buffers, int maxByteCount) バッファに指定された最大バイト数まで同じように動作するDataBufferUtils.join(Publisher)
のバリアント。static Publisher<DataBuffer>
DataBufferUtils.outputStreamPublisher
(ConsumerSE<OutputStreamSE> outputStreamConsumer, DataBufferFactory bufferFactory, ExecutorSE executor) OutputStream
に書き込まれたバイトに基づいて、新しいPublisher<DataBuffer>
を作成します。static Publisher<DataBuffer>
DataBufferUtils.outputStreamPublisher
(ConsumerSE<OutputStreamSE> outputStreamConsumer, DataBufferFactory bufferFactory, ExecutorSE executor, int chunkSize) OutputStream
に書き込まれたバイトに基づいて、新しいPublisher<DataBuffer>
を作成します。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.read
(PathSE path, DataBufferFactory bufferFactory, int bufferSize, OpenOptionSE... options) 指定されたファイルPath
からDataBuffer
のFlux
にバイトを読み取ります。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.read
(Resource resource, long position, DataBufferFactory bufferFactory, int bufferSize) 指定されたResource
を、指定された位置からDataBuffer
のFlux
に読み込みます。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.read
(Resource resource, DataBufferFactory bufferFactory, int bufferSize) 指定されたResource
をDataBuffer
のFlux
に読み取ります。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.readAsynchronousFileChannel
(CallableSE<AsynchronousFileChannelSE> channelSupplier, long position, DataBufferFactory bufferFactory, int bufferSize) 指定されたサプライヤーからAsynchronousFileChannel
を取得し、指定された位置から始めて、DataBuffer
のFlux
に読み込みます。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.readAsynchronousFileChannel
(CallableSE<AsynchronousFileChannelSE> channelSupplier, DataBufferFactory bufferFactory, int bufferSize) 指定されたサプライヤーからAsynchronousFileChannel
を取得し、DataBuffer
のFlux
に読み込みます。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.readByteChannel
(CallableSE<ReadableByteChannelSE> channelSupplier, DataBufferFactory bufferFactory, int bufferSize) static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.readInputStream
(CallableSE<InputStreamSE> inputStreamSupplier, DataBufferFactory bufferFactory, int bufferSize) static ConsumerSE<DataBuffer>
DataBufferUtils.releaseConsumer()
渡されたすべてのデータバッファでDataBufferUtils.release(DataBuffer)
を呼び出すコンシューマーを返します。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.write
(Publisher<? extends DataBuffer> source, AsynchronousFileChannelSE channel, long position) DataBuffers
の指定されたストリームを指定されたAsynchronousFileChannel
に書き込みます。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.write
(Publisher<DataBuffer> source, OutputStreamSE outputStream) DataBuffers
の指定されたストリームを指定されたOutputStream
に書き込みます。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.write
(Publisher<DataBuffer> source, AsynchronousFileChannelSE channel) DataBuffers
の指定されたストリームを指定されたAsynchronousFileChannel
に書き込みます。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.write
(Publisher<DataBuffer> source, WritableByteChannelSE channel) DataBuffers
の指定されたストリームを指定されたWritableByteChannel
に書き込みます。修飾子と型メソッド説明void
LimitedDataBufferList.add
(int index, DataBuffer buffer) boolean
LimitedDataBufferList.add
(DataBuffer buffer) int
DataBufferUtils.Matcher.match
(DataBuffer dataBuffer) 最初に一致する区切り文字を見つけて、区切り文字の最後のバイトのインデックスを返します。見つからない場合は-1
を返します。static boolean
DataBufferUtils.release
(DataBuffer dataBuffer) 指定されたデータバッファーを解放します。LimitedDataBufferList.set
(int index, DataBuffer element) static io.netty5.buffer.Buffer
Netty5DataBufferFactory.toBuffer
(DataBuffer buffer) 指定された NettyDataBuffer
をBuffer
として返します。static io.netty.buffer.ByteBuf
NettyDataBufferFactory.toByteBuf
(DataBuffer dataBuffer) 指定された NettyDataBuffer
をByteBuf
として返します。DataBuffer.write
(DataBuffer... buffers) 現在の書き込み位置から開始して、このバッファーに 1 つ以上のDataBuffer
を書き込みます。DataBufferWrapper.write
(DataBuffer... buffers) DefaultDataBuffer.write
(DataBuffer... dataBuffers) Netty5DataBuffer.write
(DataBuffer... dataBuffers) NettyDataBuffer.write
(DataBuffer... dataBuffers) 修飾子と型メソッド説明boolean
LimitedDataBufferList.addAll
(int index, CollectionSE<? extends DataBuffer> collection) boolean
LimitedDataBufferList.addAll
(CollectionSE<? extends DataBuffer> collection) DataBufferFactory.join
(ListSE<? extends DataBuffer> dataBuffers) 一緒に結合されたdataBuffers
要素で構成される新しいDataBuffer
を返します。static reactor.core.publisher.Mono<DataBuffer>
DataBufferUtils.join
(Publisher<? extends DataBuffer> dataBuffers) 指定されたdataBuffers
要素を結合して構成される新しいDataBuffer
を返します。static reactor.core.publisher.Mono<DataBuffer>
DataBufferUtils.join
(Publisher<? extends DataBuffer> buffers, int maxByteCount) バッファに指定された最大バイト数まで同じように動作するDataBufferUtils.join(Publisher)
のバリアント。DefaultDataBufferFactory.join
(ListSE<? extends DataBuffer> dataBuffers) 一緒に結合されたdataBuffers
要素で構成される新しいDataBuffer
を返します。Netty5DataBufferFactory.join
(ListSE<? extends DataBuffer> dataBuffers) 一緒に結合されたdataBuffers
要素で構成される新しいDataBuffer
を返します。NettyDataBufferFactory.join
(ListSE<? extends DataBuffer> dataBuffers) 一緒に結合されたdataBuffers
要素で構成される新しいDataBuffer
を返します。boolean
LimitedDataBufferList.removeIf
(PredicateSE<? super DataBuffer> filter) static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.write
(Publisher<? extends DataBuffer> source, AsynchronousFileChannelSE channel, long position) DataBuffers
の指定されたストリームを指定されたAsynchronousFileChannel
に書き込みます。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.write
(Publisher<DataBuffer> source, OutputStreamSE outputStream) DataBuffers
の指定されたストリームを指定されたOutputStream
に書き込みます。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.write
(Publisher<DataBuffer> source, AsynchronousFileChannelSE channel) DataBuffers
の指定されたストリームを指定されたAsynchronousFileChannel
に書き込みます。static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils.write
(Publisher<DataBuffer> source, WritableByteChannelSE channel) DataBuffers
の指定されたストリームを指定されたWritableByteChannel
に書き込みます。static reactor.core.publisher.Mono<VoidSE>
DataBufferUtils.write
(Publisher<DataBuffer> source, PathSE destination, OpenOptionSE... options) 指定されたDataBuffers
のストリームを指定されたファイルPath
SE に書き込みます。org.springframework.http 内の DataBuffer 使用
修飾子と型メソッド説明reactor.core.publisher.Flux<DataBuffer>
ReactiveHttpInputMessage.getBody()
メッセージの本文をPublisher
として返します。修飾子と型メソッド説明reactor.core.publisher.Mono<VoidSE>
ReactiveHttpOutputMessage.writeAndFlushWith
(Publisher<? extends Publisher<? extends DataBuffer>> body) Publishers
の指定されたPublisher
を使用して、HttpOutputMessage の本体を基礎となる HTTP レイヤーに書き込み、各Publisher<DataBuffer>
の後にフラッシュします。reactor.core.publisher.Mono<VoidSE>
ReactiveHttpOutputMessage.writeWith
(Publisher<? extends DataBuffer> body) 指定されたPublisher
を使用して、メッセージの本文を基礎となる HTTP レイヤーに書き込みます。org.springframework.http.client.reactive 内の DataBuffer 使用
修飾子と型メソッド説明reactor.core.publisher.Flux<DataBuffer>
AbstractClientHttpResponse.getBody()
reactor.core.publisher.Flux<DataBuffer>
ClientHttpResponseDecorator.getBody()
修飾子と型メソッド説明reactor.core.publisher.Mono<VoidSE>
ClientHttpRequestDecorator.writeAndFlushWith
(Publisher<? extends Publisher<? extends DataBuffer>> body) reactor.core.publisher.Mono<VoidSE>
ClientHttpRequestDecorator.writeWith
(Publisher<? extends DataBuffer> body) 修飾子コンストラクター説明protected
AbstractClientHttpResponse
(HttpStatusCode statusCode, HttpHeaders headers, MultiValueMap<StringSE, ResponseCookie> cookies, reactor.core.publisher.Flux<DataBuffer> body) org.springframework.http.codec 内の DataBuffer 使用
修飾子と型メソッド説明KotlinSerializationBinaryEncoder.encodeValue
(ObjectSE value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) KotlinSerializationStringEncoder.encodeValue
(ObjectSE value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明reactor.core.publisher.Flux<DataBuffer>
KotlinSerializationBinaryEncoder.encode
(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Flux<DataBuffer>
KotlinSerializationStringEncoder.encode
(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明reactor.core.publisher.Flux<ObjectSE>
KotlinSerializationBinaryDecoder.decode
(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Flux<ObjectSE>
KotlinSerializationStringDecoder.decode
(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Mono<ObjectSE>
KotlinSerializationBinaryDecoder.decodeToMono
(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Mono<ObjectSE>
KotlinSerializationStringDecoder.decodeToMono
(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) org.springframework.http.codec.cbor 内の DataBuffer 使用
修飾子と型メソッド説明reactor.core.publisher.Flux<DataBuffer>
Jackson2CborEncoder.encode
(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明reactor.core.publisher.Flux<ObjectSE>
Jackson2CborDecoder.decode
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) org.springframework.http.codec.json 内の DataBuffer 使用
修飾子と型メソッド説明AbstractJackson2Encoder.encodeValue
(ObjectSE value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明reactor.core.publisher.Flux<DataBuffer>
AbstractJackson2Encoder.encode
(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) protected reactor.core.publisher.Flux<DataBuffer>
AbstractJackson2Decoder.processInput
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 入力パブリッシャーを flux に処理します。protected reactor.core.publisher.Flux<DataBuffer>
Jackson2JsonDecoder.processInput
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明AbstractJackson2Decoder.decode
(DataBuffer dataBuffer, ResolvableType targetType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明reactor.core.publisher.Flux<ObjectSE>
AbstractJackson2Decoder.decode
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Mono<ObjectSE>
AbstractJackson2Decoder.decodeToMono
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) protected reactor.core.publisher.Flux<DataBuffer>
AbstractJackson2Decoder.processInput
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 入力パブリッシャーを flux に処理します。protected reactor.core.publisher.Flux<DataBuffer>
Jackson2JsonDecoder.processInput
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) org.springframework.http.codec.multipart 内の DataBuffer 使用
修飾子と型メソッド説明reactor.core.publisher.Flux<DataBuffer>
Part.content()
このパーツのコンテンツを返します。protected reactor.core.publisher.Mono<DataBuffer>
MultipartWriterSupport.generateBoundaryLine
(byte[] boundary, DataBufferFactory bufferFactory) protected reactor.core.publisher.Mono<DataBuffer>
MultipartWriterSupport.generateLastLine
(byte[] boundary, DataBufferFactory bufferFactory) protected reactor.core.publisher.Mono<DataBuffer>
MultipartWriterSupport.generateNewLine
(DataBufferFactory bufferFactory) protected reactor.core.publisher.Mono<DataBuffer>
MultipartWriterSupport.generatePartHeaders
(HttpHeaders headers, DataBufferFactory bufferFactory) 修飾子と型メソッド説明static reactor.core.publisher.Flux<FilePartEvent>
FilePartEvent.create
(StringSE partName, StringSE filename, MediaType contentType, reactor.core.publisher.Flux<DataBuffer> contents) 指定された name、FilePartEvent.filename()、content-type、および content に基づいて、FilePartEvent
オブジェクトのストリームを作成します。static reactor.core.publisher.Flux<FilePartEvent>
FilePartEvent.create
(StringSE partName, StringSE filename, MediaType contentType, reactor.core.publisher.Flux<DataBuffer> contents, ConsumerSE<HttpHeaders> headersConsumer) 指定された name、FilePartEvent.filename()、content-type、および content に基づいて、FilePartEvent
オブジェクトのストリームを作成します。org.springframework.http.codec.protobuf 内の DataBuffer 使用
修飾子と型メソッド説明ProtobufEncoder.encodeValue
(com.google.protobuf.Message message, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明reactor.core.publisher.Flux<DataBuffer>
ProtobufEncoder.encode
(Publisher<? extends com.google.protobuf.Message> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明com.google.protobuf.Message
ProtobufDecoder.decode
(DataBuffer dataBuffer, ResolvableType targetType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明reactor.core.publisher.Flux<com.google.protobuf.Message>
ProtobufDecoder.decode
(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Mono<com.google.protobuf.Message>
ProtobufDecoder.decodeToMono
(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) org.springframework.http.codec.xml 内の DataBuffer 使用
修飾子と型メソッド説明Jaxb2XmlEncoder.encodeValue
(ObjectSE value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明protected reactor.core.publisher.Flux<DataBuffer>
Jaxb2XmlEncoder.encode
(ObjectSE value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明Jaxb2XmlDecoder.decode
(DataBuffer dataBuffer, ResolvableType targetType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) 修飾子と型メソッド説明reactor.core.publisher.Flux<ObjectSE>
Jaxb2XmlDecoder.decode
(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Flux<XMLEventSE>
XmlEventDecoder.decode
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) reactor.core.publisher.Mono<ObjectSE>
Jaxb2XmlDecoder.decodeToMono
(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) org.springframework.http.server.reactive 内の DataBuffer 使用
修飾子と型メソッド説明protected abstract Processor<? super Publisher<? extends DataBuffer>,
VoidSE> AbstractListenerServerHttpResponse.createBodyFlushProcessor()
基になる出力にフラッシュしてレスポンス本文を書き込むProcessor<Publisher<DataBuffer>, Void>
を作成する抽象テンプレートメソッド。reactor.core.publisher.Flux<DataBuffer>
ServerHttpRequestDecorator.getBody()
修飾子と型メソッド説明protected void
AbstractServerHttpResponse.touchDataBuffer
(DataBuffer buffer) ヒントがプールされたバッファであり、リークトラッキングをサポートしている場合、サブクラスがヒントをデータバッファに関連付けることを許可します。修飾子と型メソッド説明final reactor.core.publisher.Mono<VoidSE>
AbstractServerHttpResponse.writeAndFlushWith
(Publisher<? extends Publisher<? extends DataBuffer>> body) final reactor.core.publisher.Mono<VoidSE>
HttpHeadResponseDecorator.writeAndFlushWith
(Publisher<? extends Publisher<? extends DataBuffer>> body) 書き込みなしでServerHttpResponseDecorator.setComplete()
を呼び出します。reactor.core.publisher.Mono<VoidSE>
ServerHttpResponseDecorator.writeAndFlushWith
(Publisher<? extends Publisher<? extends DataBuffer>> body) protected final reactor.core.publisher.Mono<VoidSE>
AbstractListenerServerHttpResponse.writeAndFlushWithInternal
(Publisher<? extends Publisher<? extends DataBuffer>> body) protected abstract reactor.core.publisher.Mono<VoidSE>
AbstractServerHttpResponse.writeAndFlushWithInternal
(Publisher<? extends Publisher<? extends DataBuffer>> body) 基本となるレスポンスに書き込み、各Publisher<DataBuffer>
の後にフラッシュします。final reactor.core.publisher.Mono<VoidSE>
AbstractServerHttpResponse.writeWith
(Publisher<? extends DataBuffer> body) final reactor.core.publisher.Mono<VoidSE>
HttpHeadResponseDecorator.writeWith
(Publisher<? extends DataBuffer> body) 書くことなく体を消費して解放します。reactor.core.publisher.Mono<VoidSE>
ServerHttpResponseDecorator.writeWith
(Publisher<? extends DataBuffer> body) protected final reactor.core.publisher.Mono<VoidSE>
AbstractListenerServerHttpResponse.writeWithInternal
(Publisher<? extends DataBuffer> body) protected abstract reactor.core.publisher.Mono<VoidSE>
AbstractServerHttpResponse.writeWithInternal
(Publisher<? extends DataBuffer> body) 基本となるレスポンスに書き込みます。org.springframework.messaging.handler.invocation.reactive 内の DataBuffer 使用
修飾子と型メソッド説明protected abstract reactor.core.publisher.Mono<VoidSE>
AbstractEncoderMethodReturnValueHandler.handleEncodedContent
(reactor.core.publisher.Flux<DataBuffer> encodedContent, MethodParameter returnType, Message<?> message) サブクラスは、このメソッドを実装して、メッセージの作成や送信などの何らかの方法でエンコードされた値を処理します。org.springframework.messaging.rsocket 内の DataBuffer 使用
修飾子と型メソッド説明static DataBuffer
PayloadUtils.retainDataAndReleasePayload
(io.rsocket.Payload payload, DataBufferFactory bufferFactory) このメソッドを使用して、Payload
のデータ部分をスライス、保持、ラップし、Payload
を解放します。修飾子と型メソッド説明static io.rsocket.Payload
PayloadUtils.createPayload
(DataBuffer data) データのみでペイロードを作成します。static io.rsocket.Payload
PayloadUtils.createPayload
(DataBuffer data, DataBuffer metadata) 指定されたメタデータとデータからペイロードを作成します。org.springframework.messaging.rsocket.annotation.support 内の DataBuffer 使用
修飾子と型メソッド説明protected reactor.core.publisher.Mono<VoidSE>
RSocketPayloadReturnValueHandler.handleEncodedContent
(reactor.core.publisher.Flux<DataBuffer> encodedContent, MethodParameter returnType, Message<?> message) org.springframework.mock.http.client.reactive 内の DataBuffer 使用
修飾子と型メソッド説明reactor.core.publisher.Flux<DataBuffer>
MockClientHttpRequest.getBody()
リクエストの本文、または本文が設定されていない場合、MockClientHttpRequest.setWriteHandler(java.util.function.Function<reactor.core.publisher.Flux<org.springframework.core.io.buffer.DataBuffer>, reactor.core.publisher.Mono<java.lang.Void>>)
が構成されている場合はエラーストリームを返します。reactor.core.publisher.Flux<DataBuffer>
MockClientHttpResponse.getBody()
修飾子と型メソッド説明void
MockClientHttpResponse.setBody
(Publisher<DataBuffer> body) void
MockClientHttpRequest.setWriteHandler
(FunctionSE<reactor.core.publisher.Flux<DataBuffer>, reactor.core.publisher.Mono<VoidSE>> writeHandler) リクエストの本文を書き込むためのカスタムハンドラーを構成します。reactor.core.publisher.Mono<VoidSE>
MockClientHttpRequest.writeAndFlushWith
(Publisher<? extends Publisher<? extends DataBuffer>> body) reactor.core.publisher.Mono<VoidSE>
MockClientHttpRequest.writeWith
(Publisher<? extends DataBuffer> body) org.springframework.mock.http.server.reactive 内の DataBuffer 使用
修飾子と型メソッド説明reactor.core.publisher.Flux<DataBuffer>
MockServerHttpRequest.getBody()
reactor.core.publisher.Flux<DataBuffer>
MockServerHttpResponse.getBody()
本文が設定されていない場合は、レスポンスの本文またはエラーストリームを返します。修飾子と型メソッド説明MockServerHttpRequest.BodyBuilder.body
(Publisher<? extends DataBuffer> body) リクエストの本文を設定してビルドします。void
MockServerHttpResponse.setWriteHandler
(FunctionSE<reactor.core.publisher.Flux<DataBuffer>, reactor.core.publisher.Mono<VoidSE>> writeHandler) カスタムハンドラーを構成して、レスポンス本文を消費します。protected reactor.core.publisher.Mono<VoidSE>
MockServerHttpResponse.writeAndFlushWithInternal
(Publisher<? extends Publisher<? extends DataBuffer>> body) protected reactor.core.publisher.Mono<VoidSE>
MockServerHttpResponse.writeWithInternal
(Publisher<? extends DataBuffer> body) org.springframework.web.reactive.function 内の DataBuffer 使用
修飾子と型メソッド説明static <T extends Publisher<DataBuffer>>
BodyInserter<T,ReactiveHttpOutputMessage> BodyInserters.fromDataBuffers
(T publisher) 指定されたPublisher<DataBuffer>
を本文に書き込むための挿入子。static <T extends Publisher<DataBuffer>>
BodyInserter<T,ReactiveHttpOutputMessage> BodyInserters.fromOutputStream
(ConsumerSE<OutputStreamSE> outputStreamConsumer, ExecutorSE executor) OutputStream
に書き込まれたバイトに基づくインサーター。static <T extends Publisher<DataBuffer>>
BodyInserter<T,ReactiveHttpOutputMessage> BodyInserters.fromOutputStream
(ConsumerSE<OutputStreamSE> outputStreamConsumer, ExecutorSE executor, int chunkSize) OutputStream
に書き込まれたバイトに基づくインサーター。修飾子と型メソッド説明static BodyExtractor<reactor.core.publisher.Flux<DataBuffer>,
ReactiveHttpInputMessage> BodyExtractors.toDataBuffers()
生のDataBuffers
を返すエクストラクター。org.springframework.web.reactive.function.client 内の DataBuffer 使用
修飾子と型メソッド説明ClientResponse.Builder.body
(FunctionSE<reactor.core.publisher.Flux<DataBuffer>, reactor.core.publisher.Flux<DataBuffer>> transformer) ビルダーで設定されている場合は、レスポンス本文を変換します。ClientResponse.Builder.body
(FunctionSE<reactor.core.publisher.Flux<DataBuffer>, reactor.core.publisher.Flux<DataBuffer>> transformer) ビルダーで設定されている場合は、レスポンス本文を変換します。ClientResponse.Builder.body
(reactor.core.publisher.Flux<DataBuffer> body) レスポンスの本文を設定します。org.springframework.web.reactive.function.server 内の DataBuffer 使用
修飾子と型メソッド説明ServerRequest.Builder.body
(reactor.core.publisher.Flux<DataBuffer> body) リクエストの本文を設定します。org.springframework.web.reactive.socket 内の DataBuffer 使用
修飾子と型メソッド説明WebSocketSession.binaryMessage
(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションにWebSocketSession.bufferFactory()
を使用してバイナリ WebSocketMessage を作成するファクトリメソッド。WebSocketSession.pingMessage
(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションにWebSocketSession.bufferFactory()
を使用して ping WebSocketMessage を作成するファクトリメソッド。WebSocketSession.pongMessage
(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションにWebSocketSession.bufferFactory()
を使用してポン WebSocketMessage を作成するファクトリメソッド。修飾子コンストラクター説明WebSocketMessage
(WebSocketMessage.Type type, DataBuffer payload) WebSocketMessage のコンストラクター。WebSocketMessage
(WebSocketMessage.Type type, DataBuffer payload, ObjectSE nativeMessage) 基になるメッセージにアクセスできる受信メッセージのコンストラクター。org.springframework.web.reactive.socket.adapter 内の DataBuffer 使用
修飾子と型メソッド説明AbstractWebSocketSession.binaryMessage
(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) AbstractWebSocketSession.pingMessage
(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) AbstractWebSocketSession.pongMessage
(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory)
Decoder.decode(DataBuffer, ResolvableType, MimeType, Map)
を実装してください