question: public Flux < IN > drain ( ) { return Flux . empty ( ) ; }
target:  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.