public class MockClientHttpRequest extends AbstractClientHttpRequest
ClientHttpRequest
のモック実装。コンストラクターと説明 |
---|
MockClientHttpRequest(HttpMethod httpMethod, StringSE urlTemplate, ObjectSE... vars) |
MockClientHttpRequest(HttpMethod httpMethod, URISE url) |
修飾子と型 | メソッドと説明 |
---|---|
protected void | applyCookies() 基になるレスポンスに AbstractClientHttpRequest.getHeaders() からの Cookie を追加します。 |
protected void | applyHeaders() ヘッダーの変更を AbstractClientHttpRequest.getHeaders() から基になるレスポンスに適用します。 |
DataBufferFactory | bufferFactory() ボディの作成に使用できる DataBufferFactory を返します。 |
reactor.core.publisher.Flux<DataBuffer> | getBody() リクエストの本文、または本文が設定されていない場合、 setWriteHandler(java.util.function.Function<reactor.core.publisher.Flux<org.springframework.core.io.buffer.DataBuffer>, reactor.core.publisher.Mono<java.lang.Void>>) が構成されている場合はエラーストリームを返します。 |
HttpMethod | getMethod() リクエストの HTTP メソッドを返します。 |
URISE | getURI() リクエストの URI を返します。 |
reactor.core.publisher.Mono<VoidSE> | setComplete() メッセージ処理が完了したことを示し、クリーンアップまたは処理の終了タスクを実行できるようにします。たとえば、 HttpMessage.getHeaders() を介して行われたヘッダー変更を基になる HTTP メッセージに適用します(まだ適用されていない場合)。 |
void | setWriteHandler(FunctionSE<reactor.core.publisher.Flux<DataBuffer>,reactor.core.publisher.Mono<VoidSE>> writeHandler) リクエストの本文を書き込むためのカスタムハンドラーを構成します。 |
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(org.reactivestreams.Publisher<? extends DataBuffer> body) 指定された Publisher を使用して、メッセージの本文を基礎となる HTTP レイヤーに書き込みます。 |
beforeCommit, doCommit, doCommit, getCookies, getHeaders, isCommitted
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public MockClientHttpRequest(HttpMethod httpMethod, StringSE urlTemplate, ObjectSE... vars)
public MockClientHttpRequest(HttpMethod httpMethod, URISE url)
public HttpMethod getMethod()
ClientHttpRequest
public URISE getURI()
ClientHttpRequest
public DataBufferFactory bufferFactory()
ReactiveHttpOutputMessage
DataBufferFactory
を返します。ReactiveHttpOutputMessage.writeWith(Publisher)
public reactor.core.publisher.Flux<DataBuffer> getBody()
setWriteHandler(java.util.function.Function<reactor.core.publisher.Flux<org.springframework.core.io.buffer.DataBuffer>, reactor.core.publisher.Mono<java.lang.Void>>)
が構成されている場合はエラーストリームを返します。public void setWriteHandler(FunctionSE<reactor.core.publisher.Flux<DataBuffer>,reactor.core.publisher.Mono<VoidSE>> writeHandler)
デフォルトの書き込みハンドラーは、リクエストボディを消費してキャッシュするため、後でアクセスできます。テストアサーション。このプロパティは、リクエストの本文が無限ストリームの場合に使用します。
writeHandler
- ボディが「書き込まれた」(つまり、消費された)ときに Mono<Void>
を返すための書き込みハンドラー。protected void applyHeaders()
AbstractClientHttpRequest
AbstractClientHttpRequest.getHeaders()
から基になるレスポンスに適用します。このメソッドは 1 回だけ呼び出されます。AbstractClientHttpRequest
の applyHeaders
protected void applyCookies()
AbstractClientHttpRequest
AbstractClientHttpRequest.getHeaders()
からの Cookie を追加します。このメソッドは 1 回だけ呼び出されます。AbstractClientHttpRequest
の applyCookies
public reactor.core.publisher.Mono<VoidSE> writeWith(org.reactivestreams.Publisher<? extends DataBuffer> body)
ReactiveHttpOutputMessage
Publisher
を使用して、メッセージの本文を基礎となる HTTP レイヤーに書き込みます。body
- 本文コンテンツ発行者 Mono
public reactor.core.publisher.Mono<VoidSE> writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
ReactiveHttpOutputMessage
Publishers
の指定された Publisher
を使用して、HttpOutputMessage の本体を基礎となる HTTP レイヤーに書き込み、各 Publisher<DataBuffer>
の後にフラッシュします。body
- 本文コンテンツ発行者 Mono
public reactor.core.publisher.Mono<VoidSE> setComplete()
ReactiveHttpOutputMessage
HttpMessage.getHeaders()
を介して行われたヘッダー変更を基になる HTTP メッセージに適用します(まだ適用されていない場合)。このメソッドは、メッセージ処理の最後に自動的に呼び出される必要があるため、通常はアプリケーションで呼び出す必要はありません。複数回呼び出された場合、副作用はありません。
Mono