@Test public void testExceptionallyExecution() throws SQLException { Database database = new Database(sessionFactory, 1); StepVerifier.create(database.execute(entityManager -> { throw new RuntimeException(); }).mono()) .verifyError(); }
public <T> ReactiveExecutionBuilder<T> execute(Function<EntityManager, T> function) { return new ReactiveExecutionBuilder<>(function, this); }
Database { public <T> ReactiveExecutionBuilder<T> execute(Function<EntityManager, T> function) { return new ReactiveExecutionBuilder<>(function, this); } }
Database { public <T> ReactiveExecutionBuilder<T> execute(Function<EntityManager, T> function) { return new ReactiveExecutionBuilder<>(function, this); } Database(Map<String, String> settings, List<String> resourcePackages);  Database(Map<String, String> settings, List<String> resourcePackages,
      PoolConfiguration configuration);  Database(SessionFactory sessionFactory, int maxPoolSize); }
Database { public <T> ReactiveExecutionBuilder<T> execute(Function<EntityManager, T> function) { return new ReactiveExecutionBuilder<>(function, this); } Database(Map<String, String> settings, List<String> resourcePackages);  Database(Map<String, String> settings, List<String> resourcePackages,
      PoolConfiguration configuration);  Database(SessionFactory sessionFactory, int maxPoolSize); ReactiveExecutionBuilder<T> execute(Function<EntityManager, T> function); StreamerBuilder<T> stream(String query, Class<T> type); }
Database { public <T> ReactiveExecutionBuilder<T> execute(Function<EntityManager, T> function) { return new ReactiveExecutionBuilder<>(function, this); } Database(Map<String, String> settings, List<String> resourcePackages);  Database(Map<String, String> settings, List<String> resourcePackages,
      PoolConfiguration configuration);  Database(SessionFactory sessionFactory, int maxPoolSize); ReactiveExecutionBuilder<T> execute(Function<EntityManager, T> function); StreamerBuilder<T> stream(String query, Class<T> type);  }