TailableCursor

// Find All, Subscribe, Be Active until disposed or completed.
Disposable subscription = taxiRepository.findWithTailableCursorBy() 
  .doOnNext(System.out::println) 
  .doOnComplete(() -> System.out.println("Finished")) 
  .doOnTerminate(() -> System.out.println("Terminated")) 
  .subscribe();

Thread.sleep(1000);

taxiRepository.save(new Taxi(UUID.randomUUID().toString(), "ABC-1234", 4)).subscribe();
Thread.sleep(100);

taxiRepository.save(new Taxi(UUID.randomUUID().toString(), "XYZ-1234", 4)).subscribe();
Thread.sleep(1000);
subscription.dispose();

taxiRepository.save(new Taxi(UUID.randomUUID().toString(), "DEF-1234", 4)).subscribe();