startupPing method

Future startupPing()

Implementation

Future startupPing() async {
  if (!_ready.isCompleted) {
    log.info("Sending boss our channel init message: attempt $_initCount");
    boss!.send(GruntMessages.kReady);
    _initCount++;
    await Future.delayed(Duration(milliseconds: 500), startupPing);
  } else {
    log.info("Boss got our ready message");
  }
}