onMessage method

Future<void> onMessage(
  1. I data, [
  2. Channel channel = kAnyChannel
])

Implementation

Future<void> onMessage(I data, [Channel channel = kAnyChannel]) async {
  try {
    final result = await decodeChannel(data, channel);
    if (result == null) return;
    final (rawData, rawChannel) = result;
    _readController.add(NetworkerPacket(rawData, rawChannel));
    for (final plugin in _pipes.keys) {
      try {
        plugin.onMessage(rawData, rawChannel);
      } catch (_) {}
    }
  } catch (_) {}
}