WWDuplexChannel constructor

WWDuplexChannel(
  1. PayloadHandler encoding, {
  2. 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);
    }
  });
}