@Test void should_delete_stock_when_delete_by_id_given_valid_input() { given(delete.bind(stock1.getSymbol(), stock1.getDate())).willReturn(bound); given(session.executeReactive(bound)).willReturn(new MockReactiveResultSet()); var stockRepository = new ReactiveStockRepository(session, insert, delete, findById, findBySymbol, rowMapper); var mono = stockRepository.deleteById(stock1.getSymbol(), stock1.getDate()); StepVerifier.create(mono).expectComplete().verify(); verify(session).executeReactive(bound); }
@NonNull public Mono<Void> deleteById(@NonNull String symbol, @NonNull Instant date) { BoundStatement bound = deleteById.bind(symbol, date); ReactiveResultSet rs = session.executeReactive(bound); return Mono.fromDirect(rs).then(); }
ReactiveStockRepository { @NonNull public Mono<Void> deleteById(@NonNull String symbol, @NonNull Instant date) { BoundStatement bound = deleteById.bind(symbol, date); ReactiveResultSet rs = session.executeReactive(bound); return Mono.fromDirect(rs).then(); } }
ReactiveStockRepository { @NonNull public Mono<Void> deleteById(@NonNull String symbol, @NonNull Instant date) { BoundStatement bound = deleteById.bind(symbol, date); ReactiveResultSet rs = session.executeReactive(bound); return Mono.fromDirect(rs).then(); } ReactiveStockRepository(
      CqlSession session,
      @Qualifier("stocks.prepared.insert") PreparedStatement insert,
      @Qualifier("stocks.prepared.deleteById") PreparedStatement deleteById,
      @Qualifier("stocks.prepared.findById") PreparedStatement findById,
      @Qualifier("stocks.prepared.findBySymbol") PreparedStatement findBySymbol,
      Function<Row, Stock> rowMapper); }
ReactiveStockRepository { @NonNull public Mono<Void> deleteById(@NonNull String symbol, @NonNull Instant date) { BoundStatement bound = deleteById.bind(symbol, date); ReactiveResultSet rs = session.executeReactive(bound); return Mono.fromDirect(rs).then(); } ReactiveStockRepository(
      CqlSession session,
      @Qualifier("stocks.prepared.insert") PreparedStatement insert,
      @Qualifier("stocks.prepared.deleteById") PreparedStatement deleteById,
      @Qualifier("stocks.prepared.findById") PreparedStatement findById,
      @Qualifier("stocks.prepared.findBySymbol") PreparedStatement findBySymbol,
      Function<Row, Stock> rowMapper); @NonNull Mono<Stock> save(@NonNull Stock stock); @NonNull Mono<Void> deleteById(@NonNull String symbol, @NonNull Instant date); @NonNull Mono<Stock> findById(@NonNull String symbol, @NonNull Instant date); @NonNull Flux<Stock> findAllBySymbol(
      @NonNull String symbol,
      @NonNull Instant start,
      @NonNull Instant end,
      long offset,
      long limit); }
ReactiveStockRepository { @NonNull public Mono<Void> deleteById(@NonNull String symbol, @NonNull Instant date) { BoundStatement bound = deleteById.bind(symbol, date); ReactiveResultSet rs = session.executeReactive(bound); return Mono.fromDirect(rs).then(); } ReactiveStockRepository(
      CqlSession session,
      @Qualifier("stocks.prepared.insert") PreparedStatement insert,
      @Qualifier("stocks.prepared.deleteById") PreparedStatement deleteById,
      @Qualifier("stocks.prepared.findById") PreparedStatement findById,
      @Qualifier("stocks.prepared.findBySymbol") PreparedStatement findBySymbol,
      Function<Row, Stock> rowMapper); @NonNull Mono<Stock> save(@NonNull Stock stock); @NonNull Mono<Void> deleteById(@NonNull String symbol, @NonNull Instant date); @NonNull Mono<Stock> findById(@NonNull String symbol, @NonNull Instant date); @NonNull Flux<Stock> findAllBySymbol(
      @NonNull String symbol,
      @NonNull Instant start,
      @NonNull Instant end,
      long offset,
      long limit);  }