reload method

Implementation

void reload() async {
  try {
    if (worker == null && streamWorker == null) {
      throw Exception('worker or streamWorker must be defined');
    }
    if (worker != null) {
      resolve(await worker!((v) => update(v)));
      return;
    }
    _workerSubscription = (await streamWorker!(update))
        .listen(resolve, onError: (e) => _streamCtrl.addError(e));
  } catch (e) {
    if (!_streamCtrl.isClosed) _streamCtrl.addError(e);
  }
}