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