public static <T>ReactiveSeq<T> fromPublisher(final Publisher<? extends T> publisher){
  Objects.requireNonNull(publisher);
  final SeqSubscriber<T> sub=SeqSubscriber.subscriber();
  publisher.subscribe(sub);
  return sub.stream();
}

public static < T > ReactiveSeq < T > fromPublisher ( final Publisher < ? extends T > publisher ) { Objects . requireNonNull ( publisher ) ; final SeqSubscriber < T > sub = SeqSubscriber . subscriber ( ) ; publisher . subscribe ( sub ) ; return sub . stream ( ) ; }
construct a reactiveseq from an publisher
