addData method

  1. @override
void addData(
  1. dynamic data
)
inherited

Implementation

@override
void addData(dynamic data) {
  dynamic messageData = data;
  if (data is StreamState) {
    if (_quque.actived) {
      _quque.addEventTask(close);
    } else {
      close();
    }
    return;
  }
  if (messageData is TransferType<T>) {
    _quque.addEventTask(
      () => messageData.decode().then((value) {
        if (!isCanceled) add(value);
      }),
    );
    return;
  } else if (T == dynamic && messageData is TransferableTypedData) {
    messageData = messageData.materialize();
  }
  add(messageData);
}