code: @Override
      public void subscribe(final Subscriber<? super T> s) {
  
         transformerStream().forEach(v->v.subscribe(s));
  
      }
docs: /* (non-Javadoc)
  @see com.oath.cyclops.types.Traversable#forEachAsync(org.reactivestreams.Subscriber)