WWDuplexChannel constructor
WWDuplexChannel(
- PayloadHandler encoding, {
- String? channelName,
Implementation
WWDuplexChannel(this.encoding, {String? channelName})
: log = Logger(channelName ?? 'webworker') {
log.info("Inside web worker, setting up onmessage listener for supervisor");
onMessage = allowInterop((event) {
try {
if (event is MessageEvent) {
log.info("WebWorker received raw message: ${event.data}");
_inbound.add(DecodedMessage.decoded(event.data, encoding));
} else {
log.warning("Got non-message event: $event");
}
} catch (e, stack) {
log.severe("ERROR LISTENING TO EVENT: $e", e, stack);
}
});
}