newQueue method Null safety

StreamQueue<T> newQueue()

Creates a new copy of the parent queue.

This copy starts at the parent queue's position when StreamQueue.startTransaction was called. Its position can be committed to the parent queue using commit.

Implementation

StreamQueue<T> newQueue() {
  var queue = StreamQueue(_splitter.split());
  _queues.add(queue);
  return queue;
}