code: public final void subscribe(IxConsumer<? super T> onNext, IxConsumer<Throwable> onError) {
          try {
              for (T v : this) {
                  onNext.accept(v);
              }
          } catch (Throwable ex) {
              onError.accept(ex);
          }
      }
docs: Iterates over this sequence and calls the given onNext action with
  each element and calls the onError with any exception thrown by the iteration
  or the onNext action.
  @param onNext the consumer to call with each element
  @param onError the consumer to call with the exception thrown
  @throws NullPointerException if onError is null
  @since 1.0