addData method
void
addData(
- 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);
}