@Override
    @NonNull
    public Flowable<Changes> observeChangesInTables(@NonNull final Set<String> tables, @NonNull BackpressureStrategy backpressureStrategy) {
        // indirect usage of RxJava filter() required to avoid problems with ClassLoader when RxJava is not in ClassPath
        return ChangesFilter.applyForTables(observeChanges(backpressureStrategy), tables);
    }
@ Override @ NonNull public Flowable < Changes > observeChangesInTables ( @ NonNull final Set < String > tables , @ NonNull BackpressureStrategy backpressureStrategy ) { return ChangesFilter . applyForTables ( observeChanges ( backpressureStrategy ) , tables ) ; }
{@inheritDoc}