flush method

@override void flush(TakeCallback<List> callback)

Used to extract all buffered messages from the channel. The flush is resolved using the following rules

• If the channel is closed and there are no buffered messages, then callback is invoked with End
• Otherwise callback is invoked with all buffered messages.

Implementation

@override
void flush(TakeCallback<List<T>> callback) {
  _channel.flush(callback);
}