public Flux<IN> drain(){
  return Flux.empty();
}

public Flux < IN > drain ( ) { return Flux . empty ( ) ; }
drain is a hot replication of the current buffer delivered if supported . since it is hot there might be no guarantee to see a end if the buffer keeps replenishing due to concurrent producing .
