File tree Expand file tree Collapse file tree 1 file changed +11
-9
lines changed
packages/networker/networker/lib/src/plugin Expand file tree Collapse file tree 1 file changed +11
-9
lines changed Original file line number Diff line number Diff line change @@ -45,15 +45,17 @@ abstract class NetworkerPipe<I, O> {
4545 }
4646
4747 Future <void > onMessage (I data, [Channel channel = kAnyChannel]) async {
48- final result = await decodeChannel (data, channel);
49- if (result == null ) return ;
50- final (rawData, rawChannel) = result;
51- _readController.add (NetworkerPacket (rawData, rawChannel));
52- for (final plugin in _pipes.keys) {
53- try {
54- plugin.onMessage (rawData, rawChannel);
55- } catch (_) {}
56- }
48+ try {
49+ final result = await decodeChannel (data, channel);
50+ if (result == null ) return ;
51+ final (rawData, rawChannel) = result;
52+ _readController.add (NetworkerPacket (rawData, rawChannel));
53+ for (final plugin in _pipes.keys) {
54+ try {
55+ plugin.onMessage (rawData, rawChannel);
56+ } catch (_) {}
57+ }
58+ } catch (_) {}
5759 }
5860
5961 void _sendMessagePacket (NetworkerPacket packet) =>
You can’t perform that action at this time.
0 commit comments