以下のコードのようにUserRepository
拡張されたデータを取得しようとしていますR2dbcRepository
public interface UserRepository extends R2dbcRepository<UserEntity, Long> {
Mono<UserEntity> findByEmail(String email);
}
このリポジトリはUserEntity
インスタンスの保存では正常に機能しますが、メソッドを呼び出すと機能しませんfindByEmail
。log()
以下のコードのように、サブスクライブしてデバッグする前にテストを作成しました。
@Test
void test2(){
this.userRepository.findByEmail("example@email.com").log().subscribe();
}
しかし、コンソールでは、通常のパブリッシャーのようには表示されませんonComplete
。onNext
代わりに、次のメッセージのみが表示されます。
[main] reactor.Mono.Next.1 : onSubscribe(MonoNext.NextSubscriber)
[main] reactor.Mono.Next.1 : request(unbounded)
そしてもちろん、データベースにはその電子メール名を持つデータがあります。
私が見逃しているステップはありますか?ありがとう!