@Test
public void basicNotify() throws InterruptedException {

    String[] tables = {"a", "b"};
    Set<String> tableSet = new HashSet<>(Arrays.asList(tables));
    Flowable<Object> flowable = RxRoom.createFlowable(mDatabase, tables);
    CountingConsumer consumer = new CountingConsumer();
    Disposable disposable = flowable.subscribe(consumer);
    assertThat(mAddedObservers.size(), CoreMatchers.is(1));
    InvalidationTracker.Observer observer = mAddedObservers.get(0);
    assertThat(consumer.mCount, CoreMatchers.is(1));
    observer.onInvalidated(tableSet);
    assertThat(consumer.mCount, CoreMatchers.is(2));
    observer.onInvalidated(tableSet);
    assertThat(consumer.mCount, CoreMatchers.is(3));
    disposable.dispose();
    observer.onInvalidated(tableSet);
    assertThat(consumer.mCount, CoreMatchers.is(3));
}