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