removeBatch method
删除一组的元素, 并发射
Implementation
Iterable<T>? removeBatch(Iterable<T> elements) {
if (_subject.isClosed) {
L.w('IO在close状态下请求发送数据');
return null;
}
_subject.add(latest?..removeWhere((it) => elements.contains(it)));
return elements;
}