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>>) が構成されている場合はエラーストリームを返します。 |
reactor.core.publisher.Mono<StringSE> | getBodyAsString() レスポンスデータを集約し、デフォルトで "Content-Type" 文字セットまたは "UTF-8" を使用して文字列に変換します。 |
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 void setWriteHandler(FunctionSE<reactor.core.publisher.Flux<DataBuffer>,reactor.core.publisher.Mono<VoidSE>> writeHandler)
デフォルトの書き込みハンドラーは、リクエストボディを消費してキャッシュするため、後でアクセスできます。テストアサーション。このプロパティは、リクエストの本文が無限ストリームの場合に使用します。
writeHandler
- ボディが「書き込まれた」(つまり、消費された)ときに Mono<Void>
を返すための書き込みハンドラー。public HttpMethod getMethod()
ClientHttpRequest
public URISE getURI()
ClientHttpRequest
public DataBufferFactory bufferFactory()
ReactiveHttpOutputMessage
DataBufferFactory
を返します。ReactiveHttpOutputMessage.writeWith(Publisher)
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
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 reactor.core.publisher.Mono<StringSE> getBodyAsString()