@override Future<Result<int>> streamPollAsync(int streamId) async { return _repository.streamPollAsync(streamId); }