code: public <T> SubscriptionWorker<Revision<T>> getSubscriptionWorkerForRevisions(Class<T> clazz, SubscriptionWorkerOptions options, String database) {
          SubscriptionWorker<Revision<T>> subscription = new SubscriptionWorker<>(clazz, options, true, _store, database);
  
          subscription.onClosed = sender -> _subscriptions.remove(sender);
          _subscriptions.put(subscription, true);
  
          return subscription;
      }
docs: It opens a subscription and starts pulling documents since a last processed document for that subscription.
  The connection options determine client and server cooperation rules like document batch sizes or a timeout in a matter of which a client
  needs to acknowledge that batch has been processed. The acknowledgment is sent after all documents are processed by subscription's handlers.
  
  There can be only a single client that is connected to a subscription.
  @param clazz Entity class
  @param options Subscription options
  @param database Target database
  @param <T> Entity class
  @return Subscription object that allows to add/remove subscription handlers.