修飾子と型 | メソッドと説明 |
---|---|
DataBuffer | DataBufferDecoder.decode(DataBuffer buffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
DataBuffer | ByteArrayEncoder.encodeValue(byte[] bytes, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
DataBuffer | NettyByteBufEncoder.encodeValue(io.netty.buffer.ByteBuf byteBuf, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
DataBuffer | ByteBufferEncoder.encodeValue(ByteBufferSE byteBuffer, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
DataBuffer | CharSequenceEncoder.encodeValue(CharSequenceSE charSequence, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
DataBuffer | 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 のオブジェクトをデータバッファにエンコードします。 |
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Flux<DataBuffer> | DataBufferDecoder.decode(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
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> | NettyByteBufEncoder.encode(Publisher<? extends io.netty.buffer.ByteBuf> 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> | ResourceRegionEncoder.encode(Publisher<? extends ResourceRegion> input, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
reactor.core.publisher.Flux<DataBuffer> | AbstractSingleValueEncoder.encode(Publisher<? extends T> 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 出力ストリームにエンコードします。 |
protected reactor.core.publisher.Flux<DataBuffer> | ResourceEncoder.encode(Resource resource, DataBufferFactory bufferFactory, ResolvableType type, 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 ストリームにエンコードします。 |
修飾子と型 | メソッドと説明 |
---|---|
byte[] | ByteArrayDecoder.decode(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
StringSE | StringDecoder.decode(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
DataBuffer | 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.netty.buffer.ByteBuf | NettyByteBufDecoder.decode(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
ByteBufferSE | ByteBufferDecoder.decode(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
Resource | 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) 使用すべきではありません。 5.2 現在、代わりに Decoder.decode(DataBuffer, ResolvableType, MimeType, Map) を実装してください |
DataBuffer | 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) を介して指定されたバッファーに適用します。 |
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Flux<T> | AbstractDataBufferDecoder.decode(Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
reactor.core.publisher.Flux<StringSE> | StringDecoder.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> | Decoder.decodeToMono(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) DataBuffer 入力ストリームを T の Mono にデコードします。 |
reactor.core.publisher.Mono<T> | AbstractDecoder.decodeToMono(Publisher<DataBuffer> inputStream, 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) |
修飾子と型 | インターフェースと説明 |
---|---|
interface | PooledDataBuffer メモリプールを共有するバッファを可能にする DataBuffer の拡張。 |
修飾子と型 | クラスと説明 |
---|---|
class | DataBufferWrapper デリゲートを適合させるためにオーバーライドできる DataBuffer インターフェースの便利な実装を提供します。 |
class | DefaultDataBuffer 内部で ByteBuffer SE を使用する DataBuffer インターフェースのデフォルト実装。 |
class | NettyDataBuffer Netty ByteBuf をラップする DataBuffer インターフェースの実装。 |
修飾子と型 | メソッドと説明 |
---|---|
static <T extends DataBuffer> | DataBufferUtils.retain(T dataBuffer) PooledDataBuffer の場合、指定されたデータバッファを保持します。 |
static <T extends DataBuffer> | DataBufferUtils.touch(T dataBuffer, ObjectSE hint) 指定されたヒントがプールされたバッファであり、リークトラッキングをサポートしている場合は、データバッファに関連付けます。 |
修飾子と型 | メソッドと説明 |
---|---|
DataBuffer | DataBufferFactory.allocateBuffer() デフォルトの初期容量のデータバッファを割り当てます。 |
DataBuffer | DataBufferFactory.allocateBuffer(int initialCapacity) 指定された初期容量のデータバッファーを割り当てます。 |
DataBuffer | DataBuffer.capacity(int capacity) このバッファに含めることができるバイト数を設定します。 |
DataBuffer | DataBufferWrapper.capacity(int capacity) |
DataBuffer | DataBufferWrapper.dataBuffer() ラップされたデリゲートを返します。 |
DataBuffer | NettyDataBuffer.ensureCapacity(int capacity) |
default DataBuffer | DataBuffer.ensureCapacity(int capacity) 現在のバッファーに、引数として指定されたデータ量を書き込むのに十分な writableByteCount() があることを確認してください。 |
DataBuffer | DataBufferWrapper.ensureCapacity(int capacity) |
DataBuffer | DefaultDataBuffer.ensureCapacity(int length) |
DataBuffer | DataBufferFactory.join(ListSE<? extends DataBuffer> dataBuffers) 一緒に結合された dataBuffers 要素で構成される新しい DataBuffer を返します。 |
DataBuffer | NettyDataBufferFactory.join(ListSE<? extends DataBuffer> dataBuffers) 一緒に結合された dataBuffers 要素で構成される新しい DataBuffer を返します。 |
DataBuffer | DataBuffer.read(byte[] destination) このバッファの現在の読み取り位置から開始して、指定された宛先にこのバッファのデータを読み取ります。 |
DataBuffer | DataBufferWrapper.read(byte[] destination) |
DataBuffer | DataBuffer.read(byte[] destination, int offset, int length) このバッファーの現在の読み取り位置から開始して、指定された宛先にこのバッファーの最大 length バイトを読み取ります。 |
DataBuffer | DataBufferWrapper.read(byte[] destination, int offset, int length) |
DataBuffer | DataBuffer.readPosition(int readPosition) このバッファが読み込む位置を設定します。 |
DataBuffer | DataBufferWrapper.readPosition(int readPosition) |
DataBuffer | LimitedDataBufferList.remove(int index) |
default DataBuffer | DataBuffer.retainedSlice(int index, int length) コンテンツがこのデータバッファのコンテンツの共有され、保持されたサブシーケンスである新しい DataBuffer を作成します。 |
DataBuffer | DataBufferWrapper.retainedSlice(int index, int length) |
DataBuffer | LimitedDataBufferList.set(int index, DataBuffer element) |
DataBuffer | DataBuffer.slice(int index, int length) コンテンツがこのデータバッファのコンテンツの共有サブシーケンスである新しい DataBuffer を作成します。 |
DataBuffer | DataBufferWrapper.slice(int index, int length) |
DataBuffer | DataBufferFactory.wrap(byte[] bytes) 指定された byte 配列を DataBuffer でラップします。 |
DataBuffer | NettyDataBufferFactory.wrap(byte[] bytes) |
DataBuffer | DataBufferFactory.wrap(ByteBufferSE byteBuffer) 指定された ByteBuffer SE を DataBuffer でラップします。 |
DataBuffer | DataBuffer.write(byte b) このバッファの現在の書き込み位置に 1 バイトを書き込みます。 |
DataBuffer | DataBufferWrapper.write(byte b) |
DataBuffer | DataBuffer.write(byte[] source) このバッファの現在の書き込み位置から開始して、指定されたソースをこのバッファに書き込みます。 |
DataBuffer | DataBufferWrapper.write(byte[] source) |
DataBuffer | DataBuffer.write(byte[] source, int offset, int length) このバッファの現在の書き込み位置から開始して、指定されたソースの最大 length バイトをこのバッファに書き込みます。 |
DataBuffer | DataBufferWrapper.write(byte[] source, int offset, int length) |
DataBuffer | DataBuffer.write(ByteBufferSE... buffers) 現在の書き込み位置から開始して、このバッファーに 1 つ以上の ByteBuffer SE を書き込みます。 |
DataBuffer | DataBufferWrapper.write(ByteBufferSE... buffers) |
DataBuffer | NettyDataBuffer.write(CharSequenceSE charSequence, CharsetSE charset) |
default DataBuffer | DataBuffer.write(CharSequenceSE charSequence, CharsetSE charset) 現在の書き込み位置から、指定された Charset を使用して、指定された CharSequence を書き込みます。 |
DataBuffer | DataBufferWrapper.write(CharSequenceSE charSequence, CharsetSE charset) |
DataBuffer | DataBuffer.write(DataBuffer... buffers) 現在の書き込み位置から開始して、このバッファーに 1 つ以上の DataBuffer を書き込みます。 |
DataBuffer | DataBufferWrapper.write(DataBuffer... buffers) |
DataBuffer | DataBuffer.writePosition(int writePosition) このバッファが書き込む位置を設定します。 |
DataBuffer | 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 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, DataBufferFactory bufferFactory, int bufferSize) 指定された Resource を 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.readAsynchronousFileChannel(CallableSE<AsynchronousFileChannelSE> channelSupplier, DataBufferFactory bufferFactory, int bufferSize) 指定されたサプライヤーから AsynchronousFileChannel を取得し、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.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.skipUntilByteCount(Publisher<? extends DataBuffer> publisher, long maxByteCount) |
static reactor.core.publisher.Flux<DataBuffer> | DataBufferUtils.takeUntilByteCount(Publisher<? extends DataBuffer> publisher, long maxByteCount) |
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, AsynchronousFileChannelSE channel) 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, WritableByteChannelSE channel) DataBuffers の指定されたストリームを指定された WritableByteChannel に書き込みます。 |
修飾子と型 | メソッドと説明 |
---|---|
boolean | LimitedDataBufferList.add(DataBuffer buffer) |
void | LimitedDataBufferList.add(int index, DataBuffer buffer) |
int | DataBufferUtils.Matcher.match(DataBuffer dataBuffer) 最初に一致する区切り文字を見つけて、区切り文字の最後のバイトのインデックスを返します。見つからない場合は -1 を返します。 |
static boolean | DataBufferUtils.release(DataBuffer dataBuffer) 指定されたデータバッファが PooledDataBuffer であり、割り当てられている場合は、解放します。 |
DataBuffer | LimitedDataBufferList.set(int index, DataBuffer element) |
static io.netty.buffer.ByteBuf | NettyDataBufferFactory.toByteBuf(DataBuffer buffer) 指定された Netty DataBuffer を ByteBuf として返します。 |
NettyDataBuffer | NettyDataBuffer.write(DataBuffer... buffers) |
DataBuffer | DataBuffer.write(DataBuffer... buffers) 現在の書き込み位置から開始して、このバッファーに 1 つ以上の DataBuffer を書き込みます。 |
DataBuffer | DataBufferWrapper.write(DataBuffer... buffers) |
DefaultDataBuffer | DefaultDataBuffer.write(DataBuffer... buffers) |
修飾子と型 | メソッドと説明 |
---|---|
boolean | LimitedDataBufferList.addAll(CollectionSE<? extends DataBuffer> collection) |
boolean | LimitedDataBufferList.addAll(int index, CollectionSE<? extends DataBuffer> collection) |
DataBuffer | DataBufferFactory.join(ListSE<? extends DataBuffer> dataBuffers) 一緒に結合された dataBuffers 要素で構成される新しい DataBuffer を返します。 |
DefaultDataBuffer | DefaultDataBufferFactory.join(ListSE<? extends DataBuffer> dataBuffers) 一緒に結合された dataBuffers 要素で構成される新しい DataBuffer を返します。 |
DataBuffer | NettyDataBufferFactory.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) のバリアント。 |
boolean | LimitedDataBufferList.removeIf(PredicateSE<? super DataBuffer> filter) |
static reactor.core.publisher.Flux<DataBuffer> | DataBufferUtils.skipUntilByteCount(Publisher<? extends DataBuffer> publisher, long maxByteCount) |
static reactor.core.publisher.Flux<DataBuffer> | DataBufferUtils.takeUntilByteCount(Publisher<? extends DataBuffer> publisher, long maxByteCount) |
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, AsynchronousFileChannelSE channel) DataBuffers の指定されたストリームを指定された AsynchronousFileChannel に書き込みます。 |
static reactor.core.publisher.Flux<DataBuffer> | DataBufferUtils.write(Publisher<DataBuffer> source, OutputStreamSE outputStream) DataBuffers の指定されたストリームを指定された OutputStream に書き込みます。 |
static reactor.core.publisher.Mono<VoidSE> | DataBufferUtils.write(Publisher<DataBuffer> source, PathSE destination, OpenOptionSE... options) 指定された DataBuffers のストリームを指定されたファイル Path SE に書き込みます。 |
static reactor.core.publisher.Flux<DataBuffer> | DataBufferUtils.write(Publisher<DataBuffer> source, WritableByteChannelSE channel) DataBuffers の指定されたストリームを指定された WritableByteChannel に書き込みます。 |
コンストラクターと説明 |
---|
DataBufferWrapper(DataBuffer delegate) 指定されたバッファをラップする新しい DataBufferWrapper を作成します。 |
修飾子と型 | メソッドと説明 |
---|---|
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 レイヤーに書き込みます。 |
修飾子と型 | メソッドと説明 |
---|---|
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) |
修飾子と型 | メソッドと説明 |
---|---|
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) |
修飾子と型 | メソッドと説明 |
---|---|
DataBuffer | AbstractJackson2Encoder.encodeValue(ObjectSE value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
DataBuffer | KotlinSerializationJsonEncoder.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) |
reactor.core.publisher.Flux<DataBuffer> | KotlinSerializationJsonEncoder.encode(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
protected reactor.core.publisher.Flux<DataBuffer> | Jackson2JsonDecoder.processInput(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) 入力パブリッシャーをフラックスに処理します。 |
修飾子と型 | メソッドと説明 |
---|---|
ObjectSE | AbstractJackson2Decoder.decode(DataBuffer dataBuffer, ResolvableType targetType, MimeType mimeType, MapSE<StringSE, ObjectSE> hints) |
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Flux<ObjectSE> | KotlinSerializationJsonDecoder.decode(Publisher<DataBuffer> inputStream, ResolvableType elementType, 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> | KotlinSerializationJsonDecoder.decodeToMono(Publisher<DataBuffer> inputStream, 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> | Jackson2JsonDecoder.processInput(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) 入力パブリッシャーをフラックスに処理します。 |
修飾子と型 | メソッドと説明 |
---|---|
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) |
修飾子と型 | メソッドと説明 |
---|---|
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) |
修飾子と型 | メソッドと説明 |
---|---|
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) |
修飾子と型 | メソッドと説明 |
---|---|
ObjectSE | Jaxb2XmlDecoder.decode(DataBuffer dataBuffer, ResolvableType targetType, 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.Flux<ObjectSE> | Jaxb2XmlDecoder.decode(Publisher<DataBuffer> inputStream, 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) |
修飾子と型 | メソッドと説明 |
---|---|
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) ヒントがプールされたバッファであり、リークトラッキングをサポートしている場合、サブクラスがヒントをデータバッファに関連付けることを許可します。 |
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Mono<VoidSE> | HttpHeadResponseDecorator.writeAndFlushWith(Publisher<? extends Publisher<? extends DataBuffer>> body) 書き込みなしで ServerHttpResponseDecorator.setComplete() を呼び出します。 |
reactor.core.publisher.Mono<VoidSE> | AbstractServerHttpResponse.writeAndFlushWith(Publisher<? extends Publisher<? extends DataBuffer>> body) |
reactor.core.publisher.Mono<VoidSE> | ServerHttpResponseDecorator.writeAndFlushWith(Publisher<? extends Publisher<? extends DataBuffer>> body) |
protected 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> の後にフラッシュします。 |
reactor.core.publisher.Mono<VoidSE> | HttpHeadResponseDecorator.writeWith(Publisher<? extends DataBuffer> body) 書くことなく体を消費して解放します。 |
reactor.core.publisher.Mono<VoidSE> | AbstractServerHttpResponse.writeWith(Publisher<? extends DataBuffer> body) |
reactor.core.publisher.Mono<VoidSE> | ServerHttpResponseDecorator.writeWith(Publisher<? extends DataBuffer> body) |
protected reactor.core.publisher.Mono<VoidSE> | AbstractListenerServerHttpResponse.writeWithInternal(Publisher<? extends DataBuffer> body) |
protected abstract reactor.core.publisher.Mono<VoidSE> | AbstractServerHttpResponse.writeWithInternal(Publisher<? extends DataBuffer> body) 基本となるレスポンスに書き込みます。 |
修飾子と型 | メソッドと説明 |
---|---|
protected abstract reactor.core.publisher.Mono<VoidSE> | AbstractEncoderMethodReturnValueHandler.handleEncodedContent(reactor.core.publisher.Flux<DataBuffer> encodedContent, MethodParameter returnType, Message<?> message) サブクラスは、このメソッドを実装して、メッセージの作成や送信などの何らかの方法でエンコードされた値を処理します。 |
修飾子と型 | メソッドと説明 |
---|---|
static DataBuffer | PayloadUtils.retainDataAndReleasePayload(Payload payload, DataBufferFactory bufferFactory) このメソッドを使用して、 Payload のデータ部分をスライス、保持、ラップし、Payload を解放します。 |
修飾子と型 | メソッドと説明 |
---|---|
static Payload | PayloadUtils.createPayload(DataBuffer data) データのみでペイロードを作成します。 |
static Payload | PayloadUtils.createPayload(DataBuffer data, DataBuffer metadata) 指定されたメタデータとデータからペイロードを作成します。 |
修飾子と型 | メソッドと説明 |
---|---|
protected reactor.core.publisher.Mono<VoidSE> | RSocketPayloadReturnValueHandler.handleEncodedContent(reactor.core.publisher.Flux<DataBuffer> encodedContent, MethodParameter returnType, Message<?> message) |
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Flux<DataBuffer> | MockClientHttpResponse.getBody() |
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>>) が構成されている場合はエラーストリームを返します。 |
修飾子と型 | メソッドと説明 |
---|---|
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) |
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Flux<DataBuffer> | MockServerHttpResponse.getBody() 本文が設定されていない場合は、レスポンスの本文またはエラーストリームを返します。 |
reactor.core.publisher.Flux<DataBuffer> | MockServerHttpRequest.getBody() |
修飾子と型 | メソッドと説明 |
---|---|
MockServerHttpRequest | 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) |
修飾子と型 | メソッドと説明 |
---|---|
static <T extends Publisher<DataBuffer>> | BodyInserters.fromDataBuffers(T publisher) 指定された Publisher<DataBuffer> を本文に書き込むための挿入子。 |
修飾子と型 | メソッドと説明 |
---|---|
static BodyExtractor<reactor.core.publisher.Flux<DataBuffer>,ReactiveHttpInputMessage> | BodyExtractors.toDataBuffers() 生の DataBuffers を返すエクストラクター。 |
修飾子と型 | メソッドと説明 |
---|---|
ClientResponse.Builder | ClientResponse.Builder.body(reactor.core.publisher.Flux<DataBuffer> body) レスポンスの本文を設定します。 |
ClientResponse.Builder | ClientResponse.Builder.body(FunctionSE<reactor.core.publisher.Flux<DataBuffer>,reactor.core.publisher.Flux<DataBuffer>> transformer) ビルダーで設定されている場合は、レスポンス本文を変換します。 |
ClientResponse.Builder | ClientResponse.Builder.body(FunctionSE<reactor.core.publisher.Flux<DataBuffer>,reactor.core.publisher.Flux<DataBuffer>> transformer) ビルダーで設定されている場合は、レスポンス本文を変換します。 |
修飾子と型 | メソッドと説明 |
---|---|
ServerRequest.Builder | ServerRequest.Builder.body(reactor.core.publisher.Flux<DataBuffer> body) リクエストの本文を設定します。 |
修飾子と型 | メソッドと説明 |
---|---|
DataBuffer | WebSocketMessage.getPayload() メッセージのペイロードを返します。 |
修飾子と型 | メソッドと説明 |
---|---|
WebSocketMessage | WebSocketSession.binaryMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションに WebSocketSession.bufferFactory() を使用してバイナリ WebSocketMessage を作成するファクトリメソッド。 |
WebSocketMessage | WebSocketSession.pingMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションに WebSocketSession.bufferFactory() を使用して ping WebSocketMessage を作成するファクトリメソッド。 |
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) 基になるメッセージにアクセスできる受信メッセージのコンストラクター。 |
修飾子と型 | メソッドと説明 |
---|---|
WebSocketMessage | AbstractWebSocketSession.binaryMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) |
WebSocketMessage | AbstractWebSocketSession.pingMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) |
WebSocketMessage | AbstractWebSocketSession.pongMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) |