1

以下のコードのようにUserRepository拡張されたデータを取得しようとしていますR2dbcRepository

public interface UserRepository extends R2dbcRepository<UserEntity, Long> {
    Mono<UserEntity> findByEmail(String email);
}

このリポジトリはUserEntityインスタンスの保存では正常に機能しますが、メソッドを呼び出すと機能しませんfindByEmaillog()以下のコードのように、サブスクライブしてデバッグする前にテストを作成しました。

@Test
void test2(){
    this.userRepository.findByEmail("example@email.com").log().subscribe();
}

しかし、コンソールでは、通常のパブリッシャーのようには表示されませんonCompleteonNext代わりに、次のメッセージのみが表示されます。

[main] reactor.Mono.Next.1 : onSubscribe(MonoNext.NextSubscriber)
[main] reactor.Mono.Next.1 : request(unbounded)

そしてもちろん、データベースにはその電子メール名を持つデータがあります。 テーブル

私が見逃しているステップはありますか?ありがとう!

4

0 に答える 0