public FluxHandleFuseable(Publisher<? extends T> source,BiConsumer<? super T,SynchronousSink<R>> handler){
  super(source);
  this.handler=Objects.requireNonNull(handler,"handler");
}

public FluxHandleFuseable ( Publisher < ? extends T > source , BiConsumer < ? super T , SynchronousSink < R > > handler ) { super ( source ) ; this . handler = Objects . requireNonNull ( handler , "handler" ) ; }
constructs a fluxmap instance with the given source and handler .
