completeAllQueue method

void completeAllQueue(
  1. T result
)

Implementation

void completeAllQueue(T result) {
  while (_completers.isNotEmpty) {
    next?.complete(result);
  }
}