publish method

Future<void> publish(
  1. DataPackage pkt
)

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");

}