@Test
  void error() {
    RxJavaModelRepository repo = new RxJavaModelRepository(new FakeBackend(Flowable.error(new RuntimeException("boom"))));
    repo.findAll().fetch().test().awaitDone(1, TimeUnit.SECONDS).assertErrorMessage("boom");
  }
Validate the projections work with different types of facets (see {@link org.immutables.criteria.repository.Facet}).
criteria/rxjava2/test/org/immutables/criteria/repository/rxjava2/RxJavaTest.java