public interface ConnectionAccessorFunctionSE を受け入れて Connection のスコープ内で動作するメソッドを宣言するインターフェース。コールバック関数は提供された接続で動作し、接続がプールされたり、他の種類のリソース管理の対象となる可能性があるため、接続を閉じてはなりません。 コールバック関数は、割り当てられた Connection が有効である期間のスコープを定義する Publisher を作成する責任があります。パブリッシャーが終了すると、接続が解放されます。
| 修飾子と型 | メソッドと説明 |
|---|---|
<T> reactor.core.publisher.Mono<T> | inConnection(FunctionSE<Connection,reactor.core.publisher.Mono<T>> action)Connection スコープ内でコールバック FunctionSE を実行します。 |
<T> reactor.core.publisher.Flux<T> | inConnectionMany(FunctionSE<Connection,reactor.core.publisher.Flux<T>> action)Connection スコープ内でコールバック FunctionSE を実行します。 |
<T> reactor.core.publisher.Mono<T> inConnection(FunctionSE<Connection,reactor.core.publisher.Mono<T>> action) throws DataAccessException
Connection スコープ内でコールバック FunctionSE を実行します。この関数は、Mono の作成を担当します。Mono が終了した後（またはサブスクリプションがキャンセルされた後）、接続が解放されます。接続リソースを FunctionSE クロージャーの外部に渡してはなりません。渡さないと、リソースが機能しなくなる可能性があります。action - 接続アクションを指定するコールバックオブジェクト MonoDataAccessException<T> reactor.core.publisher.Flux<T> inConnectionMany(FunctionSE<Connection,reactor.core.publisher.Flux<T>> action) throws DataAccessException
Connection スコープ内でコールバック FunctionSE を実行します。この関数は、Flux の作成を担当します。Flux が終了した後（またはサブスクリプションがキャンセルされた後）、接続が解放されます。接続リソースを FunctionSE クロージャーの外部に渡してはなりません。渡さないと、リソースが機能しなくなる可能性があります。action - 接続アクションを指定するコールバックオブジェクト FluxDataAccessException