code: private void complete(Subscriber<? super T> subscriber) {
          if (!subscriber.isUnsubscribed()) {
              debug("onCompleted");
              subscriber.onCompleted();
          } else
              debug("unsubscribed");
      }
docs: Notify observer that sequence is complete.
  
  @param subscriber
  @param state