diff --git a/communication/multichannelcommunication.cpp b/communication/multichannelcommunication.cpp index 091e927..e8da7c9 100644 --- a/communication/multichannelcommunication.cpp +++ b/communication/multichannelcommunication.cpp @@ -163,14 +163,7 @@ void MultiChannelCommunication::vnetReadTask(size_t vnetIndex) { if(closing) break; - if(vnetPacketizer->input(payloadBytes)) { - for(const auto& packet : vnetPacketizer->output()) { - std::shared_ptr msg; - if(!decoder->decode(msg, packet)) - continue; // Error will have been reported from within decoder - dispatchMessage(msg); - } - } + handleInput(*vnetPacketizer, payloadBytes); } } } \ No newline at end of file