public class ReactorClientHttpRequest extends AbstractClientHttpRequest implements ZeroCopyHttpOutputMessage
ClientHttpRequest 実装。HttpClient| コンストラクターと説明 |
|---|
ReactorClientHttpRequest(HttpMethod httpMethod, URISE uri, reactor.ipc.netty.http.client.HttpClientRequest httpRequest) |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected void | applyCookies() 基になるレスポンスに AbstractClientHttpRequest.getHeaders() からの Cookie を追加します。 |
protected void | applyHeaders() ヘッダーの変更を AbstractClientHttpRequest.getHeaders() から基になるレスポンスに適用します。 |
DataBufferFactory | bufferFactory() ボディの作成に使用できる DataBufferFactory を返します。 |
HttpMethod | getMethod() リクエストの HTTP メソッドを返します。 |
URISE | getURI() リクエストの URI を返します。 |
reactor.core.publisher.Mono<VoidSE> | setComplete() メッセージ処理が完了したことを示し、クリーンアップまたは処理の終了タスクを実行できるようにします。たとえば、 HttpMessage.getHeaders() を介して行われたヘッダー変更を基になる HTTP メッセージに適用します(まだ適用されていない場合)。 |
reactor.core.publisher.Mono<VoidSE> | writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)Publishers の指定された Publisher を使用して、HttpOutputMessage の本体を基礎となる HTTP レイヤーに書き込み、各 Publisher<DataBuffer> の後にフラッシュします。 |
reactor.core.publisher.Mono<VoidSE> | writeWith(FileSE file, long position, long count) 指定された FileSE を使用して、メッセージの本文を基礎となる HTTP レイヤーに書き込みます。 |
reactor.core.publisher.Mono<VoidSE> | writeWith(org.reactivestreams.Publisher<? extends DataBuffer> body) 指定された Publisher を使用して、メッセージの本文を基礎となる HTTP レイヤーに書き込みます。 |
beforeCommit, doCommit, doCommit, getCookies, getHeaders, isCommittedcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEbeforeCommit, isCommittedgetHeaderspublic ReactorClientHttpRequest(HttpMethod httpMethod, URISE uri, reactor.ipc.netty.http.client.HttpClientRequest httpRequest)
public DataBufferFactory bufferFactory()
ReactiveHttpOutputMessageDataBufferFactory を返します。ReactiveHttpOutputMessage 内の bufferFactory ReactiveHttpOutputMessage.writeWith(Publisher)public HttpMethod getMethod()
ClientHttpRequestClientHttpRequest 内の getMethod public URISE getURI()
ClientHttpRequestClientHttpRequest 内の getURI public reactor.core.publisher.Mono<VoidSE> writeWith(org.reactivestreams.Publisher<? extends DataBuffer> body)
ReactiveHttpOutputMessagePublisher を使用して、メッセージの本文を基礎となる HTTP レイヤーに書き込みます。ReactiveHttpOutputMessage 内の writeWith body - 本文コンテンツ発行者 Mono public reactor.core.publisher.Mono<VoidSE> writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
ReactiveHttpOutputMessagePublishers の指定された Publisher を使用して、HttpOutputMessage の本体を基礎となる HTTP レイヤーに書き込み、各 Publisher<DataBuffer> の後にフラッシュします。ReactiveHttpOutputMessage 内の writeAndFlushWith body - 本文コンテンツ発行者 Mono public reactor.core.publisher.Mono<VoidSE> writeWith(FileSE file, long position, long count)
ZeroCopyHttpOutputMessageFileSE を使用して、メッセージの本文を基礎となる HTTP レイヤーに書き込みます。ZeroCopyHttpOutputMessage 内の writeWith file - 転送するファイル position - 転送を開始するファイル内の位置 count - 転送されるバイト数 public reactor.core.publisher.Mono<VoidSE> setComplete()
ReactiveHttpOutputMessageHttpMessage.getHeaders() を介して行われたヘッダー変更を基になる HTTP メッセージに適用します(まだ適用されていない場合)。このメソッドは、メッセージ処理の最後に自動的に呼び出される必要があるため、通常はアプリケーションで呼び出す必要はありません。複数回呼び出された場合、副作用はありません。
ReactiveHttpOutputMessage 内の setComplete Mono protected void applyHeaders()
AbstractClientHttpRequestAbstractClientHttpRequest.getHeaders() から基になるレスポンスに適用します。このメソッドは 1 回だけ呼び出されます。AbstractClientHttpRequest の applyHeaders protected void applyCookies()
AbstractClientHttpRequestAbstractClientHttpRequest.getHeaders() からのクッキーを基となるレスポンスに追加します。このメソッドは一度だけ呼び出されます。AbstractClientHttpRequest の applyCookies