Future waitFor() { if (isWorker) { return new Future.value(); } else { return _readyCompleter.future; } }