open method

@override Future open(String? correlationId)

Opens the component.

• correlationId (optional) transaction id to trace execution through call chain.
• callback callback function that receives error or null no errors occured.

Implementation

@override
Future open(String? correlationId) async {
  if (_interval != null) _interval!.cancel();

  var timeout = RandomInteger.nextInteger(_minTimeout, _maxTimeout);
  _interval = Timer.periodic(Duration(milliseconds: timeout), (Timer tm) {
    shutdown();
  });
}