publish method
Implementation
Future<void> publish(DataPackage pkt) async {
print("Publish 0 ${_outputPaused}");
if (_outputPaused) {
await _waitForResume();
}
print("Publish 1 ${pkt}");
print("${_outputCtrl}");
_outputCtrl!.add(pkt);
print("Publish 2");
}