code: private <T> void manageSubscription(EventStream<T> stream, Consumer<T> consumer) {
          manageSubscription(stream.subscribe(consumer));
      }
docs: /* ********************************************************************** *
  *
  Private methods                                                        *
  *
  **********************************************************************