removeBatch method

Iterable<T>? removeBatch(
  1. Iterable<T> elements
)

删除一组的元素, 并发射

Implementation

Iterable<T>? removeBatch(Iterable<T> elements) {
  if (_subject.isClosed) {
    L.w('IO在close状态下请求发送数据');
    return null;
  }

  final copied = List.of(latest);
  _subject.add(copied..removeWhere((it) => elements.contains(it)));
  return elements;
}