remove method

T? remove(T element)

删除一个的元素, 并发射

Implementation

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

  _subject.add(latest?..remove(element));
  return element;
}