@Test public void testStreamExecution() throws SQLException { setupStreamTransactionMocks(IsolationLevel.READ_COMMITTED); Database database = new Database(sessionFactory, 1); Flux<Person> stream = database .stream(DefaultStreamerTest.QUERY, Person.class) .isolationLevel(IsolationLevel.READ_COMMITTED) .addParameter("key", "value") .addParameters(Collections.emptyMap()) .fetchSize(5) .flux(); StepVerifier.withVirtualTime(() -> stream) .expectNext(DefaultStreamerTest.PERSON) .verifyComplete(); }
public <T> StreamerBuilder<T> stream(String query, Class<T> type) { return new StreamerBuilder<>(this, query, type); }
Database { public <T> StreamerBuilder<T> stream(String query, Class<T> type) { return new StreamerBuilder<>(this, query, type); } }
Database { public <T> StreamerBuilder<T> stream(String query, Class<T> type) { return new StreamerBuilder<>(this, query, type); } 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> StreamerBuilder<T> stream(String query, Class<T> type) { return new StreamerBuilder<>(this, query, type); } 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> StreamerBuilder<T> stream(String query, Class<T> type) { return new StreamerBuilder<>(this, query, type); } 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);  }