code: private Subscriber realSubs(RLPredicate<Record> filter, ChangeReceiver receiver) {
          Subscriber subs = new Subscriber(filter,receiver);
          this.realSubscribe(subs);
          return subs;
      }
docs: actually subscribes at datanodes