Future<Result<int>> streamPollAsync(int streamId) => OdbcErrorBoundary.run( 'streamPollAsync', () => _repository.streamPollAsync(streamId), );