How to use QueuedEventGroup class of PuppeteerSharp package

...160                return;161            }162            // We may have skipped response and loading events because we didn't have163            // this ExtraInfo event yet. If so, emit those events now.164            var queuedEvents = _networkEventManager.GetQueuedEventGroup(e.RequestId);165            if (queuedEvents != null)166            {167                EmitResponseEvent(queuedEvents.ResponseReceivedEvent, e);168                if (queuedEvents.LoadingFinishedEvent != null) {169                    OnLoadingFinished(queuedEvents.LoadingFinishedEvent);170                }171                if (queuedEvents.LoadingFailedEvent != null) {172                    OnLoadingFailed(queuedEvents.LoadingFailedEvent);173                }174                // We need this in .NET to avoid race conditions175                _networkEventManager.ForgetQueuedEventGroup(e.RequestId);176                return;177            }178            // Wait until we get another event that can use this ExtraInfo event.179            _networkEventManager.ResponseExtraInfo(e.RequestId).Add(e);180        }181        private void OnLoadingFailed(LoadingFailedEventResponse e)182        {183            var queuedEvents = _networkEventManager.GetQueuedEventGroup(e.RequestId);184            if (queuedEvents != null)185            {186                queuedEvents.LoadingFailedEvent = e;187            }188            else189            {190                EmitLoadingFailed(e);191            }192        }193        private void EmitLoadingFailed(LoadingFailedEventResponse e)194        {195            var request = _networkEventManager.GetRequest(e.RequestId);196            if (request == null)197            {198                return;199            }200            request.Failure = e.ErrorText;201            request.Response?.BodyLoadedTaskWrapper.TrySetResult(true);202            ForgetRequest(request, true);203            RequestFailed?.Invoke(this, new RequestEventArgs204            {205                Request = request206            });207        }208        private void OnLoadingFinished(LoadingFinishedEventResponse e)209        {210            var queuedEvents = _networkEventManager.GetQueuedEventGroup(e.RequestId);211            if (queuedEvents != null)212            {213                queuedEvents.LoadingFinishedEvent = e;214            }215            else216            {217                EmitLoadingFinished(e);218            }219        }220        private void EmitLoadingFinished(LoadingFinishedEventResponse e)221        {222            var request = _networkEventManager.GetRequest(e.RequestId);223            if (request == null)224            {225                return;226            }227            request.Response?.BodyLoadedTaskWrapper.TrySetResult(true);228            ForgetRequest(request, true);229            RequestFinished?.Invoke(this, new RequestEventArgs230            {231                Request = request232            });233        }234        private void ForgetRequest(Request request, bool events)235        {236            _networkEventManager.ForgetRequest(request.RequestId);237            if (request.InterceptionId != null)238            {239                _attemptedAuthentications.Remove(request.InterceptionId);240            }241            if (events)242            {243                _networkEventManager.Forget(request.RequestId);244            }245        }246        private void OnResponseReceived(ResponseReceivedResponse e)247        {248            var request = _networkEventManager.GetRequest(e.RequestId);249            ResponseReceivedExtraInfoResponse extraInfo = null;250            if (request != null && !request.FromMemoryCache && e.HasExtraInfo)251            {252                extraInfo = _networkEventManager.ShiftResponseExtraInfo(e.RequestId);253                if (extraInfo == null)254                {255                    _networkEventManager.QueuedEventGroup(e.RequestId, new()256                    {257                        ResponseReceivedEvent = e258                    });259                    return;260                }261            }262            EmitResponseEvent(e, extraInfo);263        }264        private void EmitResponseEvent(ResponseReceivedResponse e, ResponseReceivedExtraInfoResponse extraInfo)265        {266            var request = _networkEventManager.GetRequest(e.RequestId);267            // FileUpload sends a response without a matching request.268            if (request == null)269            {...

...9    {10        private readonly ConcurrentDictionary<string, RequestWillBeSentPayload> _requestWillBeSentMap = new();11        private readonly ConcurrentDictionary<string, FetchRequestPausedResponse> _requestPausedMap = new();12        private readonly ConcurrentDictionary<string, Request> _httpRequestsMap = new();13        private readonly ConcurrentDictionary<string, QueuedEventGroup> _queuedEventGroupMap = new();14        private readonly ConcurrentDictionary<string, List<RedirectInfo>> _queuedRedirectInfoMap = new();15        private readonly ConcurrentDictionary<string, List<ResponseReceivedExtraInfoResponse>> _responseReceivedExtraInfoMap = new();16        public int NumRequestsInProgress17            => _httpRequestsMap.Values.Count(r => r.Response == null);18        internal void Forget(string requestId)19        {20            _requestWillBeSentMap.TryRemove(requestId, out _);21            _requestPausedMap.TryRemove(requestId, out _);22            _queuedEventGroupMap.TryRemove(requestId, out _);23            _queuedRedirectInfoMap.TryRemove(requestId, out _);24            _responseReceivedExtraInfoMap.TryRemove(requestId, out _);25        }26        internal List<ResponseReceivedExtraInfoResponse> ResponseExtraInfo(string networkRequestId)27        {28            if (!_responseReceivedExtraInfoMap.ContainsKey(networkRequestId))29            {30                _responseReceivedExtraInfoMap.AddOrUpdate(31                    networkRequestId,32                    new List<ResponseReceivedExtraInfoResponse>(),33                    (_, __) => new List<ResponseReceivedExtraInfoResponse>());34            }35            _responseReceivedExtraInfoMap.TryGetValue(networkRequestId, out var result);36            return result;37        }38        private List<RedirectInfo> QueuedRedirectInfo(string fetchRequestId)39        {40            if (!_queuedRedirectInfoMap.ContainsKey(fetchRequestId))41            {42                _queuedRedirectInfoMap.TryAdd(fetchRequestId, new List<RedirectInfo>());43            }44            _queuedRedirectInfoMap.TryGetValue(fetchRequestId, out var result);45            return result;46        }47        internal void QueueRedirectInfo(string fetchRequestId, RedirectInfo redirectInfo)48            => QueuedRedirectInfo(fetchRequestId).Add(redirectInfo);49        internal RedirectInfo TakeQueuedRedirectInfo(string fetchRequestId)50        {51            var list = QueuedRedirectInfo(fetchRequestId);52            var result = list.FirstOrDefault();53            if (result != null)54            {55                list.Remove(result);56            }57            return result;58        }59        internal ResponseReceivedExtraInfoResponse ShiftResponseExtraInfo(string networkRequestId)60        {61            if (!_responseReceivedExtraInfoMap.ContainsKey(networkRequestId))62            {63                _responseReceivedExtraInfoMap.TryAdd(networkRequestId, new List<ResponseReceivedExtraInfoResponse>());64            }65            _responseReceivedExtraInfoMap.TryGetValue(networkRequestId, out var list);66            var result = list.FirstOrDefault();67            if (result != null)68            {69                list.Remove(result);70            }71            return result;72        }73        internal void StoreRequestWillBeSent(string networkRequestId, RequestWillBeSentPayload e)74            => _requestWillBeSentMap.AddOrUpdate(networkRequestId, e, (_, __) => e);75        internal RequestWillBeSentPayload GetRequestWillBeSent(string networkRequestId)76        {77            _requestWillBeSentMap.TryGetValue(networkRequestId, out var result);78            return result;79        }80        internal void ForgetRequestWillBeSent(string networkRequestId)81            => _requestWillBeSentMap.TryRemove(networkRequestId, out _);82        internal FetchRequestPausedResponse GetRequestPaused(string networkRequestId)83        {84            _requestPausedMap.TryGetValue(networkRequestId, out var result);85            return result;86        }87        internal void ForgetRequestPaused(string networkRequestId)88            => _requestPausedMap.TryRemove(networkRequestId, out _);89        internal void StoreRequestPaused(string networkRequestId, FetchRequestPausedResponse e)90            => _requestPausedMap.AddOrUpdate(networkRequestId, e, (_, __) => e);91        internal Request GetRequest(string networkRequestId)92        {93            _httpRequestsMap.TryGetValue(networkRequestId, out var result);94            return result;95        }96        internal void StoreRequest(string networkRequestId, Request request)97            => _httpRequestsMap.AddOrUpdate(networkRequestId, request, (_, __) => request);98        internal void ForgetRequest(string requestId)99            => _requestWillBeSentMap.TryRemove(requestId, out _);100        internal void QueuedEventGroup(string networkRequestId, QueuedEventGroup group)101            => _queuedEventGroupMap.AddOrUpdate(networkRequestId, group, (_, __) => group);102        internal QueuedEventGroup GetQueuedEventGroup(string networkRequestId)103        {104            _queuedEventGroupMap.TryGetValue(networkRequestId, out var result);105            return result;106        }107        // Puppeteer doesn't have this. but it seems that .NET needs this to avoid race conditions108        internal void ForgetQueuedEventGroup(string networkRequestId)109            => _queuedEventGroupMap.TryRemove(networkRequestId, out _);110    }111}...

1using PuppeteerSharp.Messaging;2namespace PuppeteerSharp3{4    internal class QueuedEventGroup5    {6        public ResponseReceivedResponse ResponseReceivedEvent { get; set; }7        public LoadingFinishedEventResponse LoadingFinishedEvent { get; set; }8        public LoadingFailedEventResponse LoadingFailedEvent { get; set; }9    }10}...

1using PuppeteerSharp;2using System;3using System.Threading.Tasks;4{5    {6        static async Task Main(string[] args)7        {8            {9            };10            var browser = await Puppeteer.LaunchAsync(options);11            var page = await browser.NewPageAsync();12            await page.WaitForSelectorAsync("input[name=q]");13            await page.TypeAsync("input[name=q]", "Puppeteer");14            await page.ClickAsync("input[value='Google Search']");15            var eventGroup = new QueuedEventGroup(page);16            eventGroup.AddEvent("load");17            eventGroup.AddEvent("domcontentloaded");18            eventGroup.AddEvent("networkidle0");19            eventGroup.AddEvent("networkidle2");20            await eventGroup.WaitForEventsAsync();21            await page.ScreenshotAsync("Puppeteer.png");22            await browser.CloseAsync();23        }24    }25}26using PuppeteerSharp;27using System;28using System.Threading.Tasks;29{30    {31        static async Task Main(string[] args)32        {33            {34            };35            var browser = await Puppeteer.LaunchAsync(options);36            var page = await browser.NewPageAsync();37            await page.WaitForSelectorAsync("input[name=q]");38            await page.TypeAsync("input[name=q]", "Puppeteer");39            await page.ClickAsync("input[value='Google Search']");40            var eventGroup = new QueuedEventGroup(page);41            eventGroup.AddEvent("load");42            eventGroup.AddEvent("domcontentloaded");43            eventGroup.AddEvent("networkidle0");44            eventGroup.AddEvent("networkidle2");45            await eventGroup.WaitForEventsAsync();46            await page.ScreenshotAsync("Puppeteer.png");47            await browser.CloseAsync();48        }49    }50}51using PuppeteerSharp;52using System;53using System.Threading.Tasks;54{

1using System;2using System.Threading.Tasks;3using PuppeteerSharp;4{5    {6        public static async Task Main(string[] args)7        {8            var browser = await Puppeteer.LaunchAsync(new LaunchOptions9            {10            });11            var page = await browser.NewPageAsync();12            var input = await page.QuerySelectorAsync("input");13            await input.TypeAsync("Hello World");14            await page.ScreenshotAsync("google.png");15            await browser.CloseAsync();16        }17    }18}19using System;20using System.Threading.Tasks;21using PuppeteerSharp;22{23    {24        public static async Task Main(string[] args)25        {26            var browser = await Puppeteer.LaunchAsync(new LaunchOptions27            {28            });29            var page = await browser.NewPageAsync();30            var input = await page.QuerySelectorAsync("input");31            await input.TypeAsync("Hello World");32            await page.ScreenshotAsync("google.png");33            await browser.CloseAsync();34        }35    }36}37using System;38using System.Threading.Tasks;39using PuppeteerSharp;40{41    {42        public static async Task Main(string[] args)43        {44            var browser = await Puppeteer.LaunchAsync(new LaunchOptions45            {46            });47            var page = await browser.NewPageAsync();48            var input = await page.QuerySelectorAsync("input");49            await input.TypeAsync("Hello World");50            await page.ScreenshotAsync("google.png");51            await browser.CloseAsync();52        }53    }54}55using System;56using System.Threading.Tasks;57using PuppeteerSharp;58{59    {60        public static async Task Main(string[] args)61        {62            var browser = await Puppeteer.LaunchAsync(new

1var options = new LaunchOptions { Headless = false };2using var browser = await Puppeteer.LaunchAsync(options);3using var page = await browser.NewPageAsync();4await page.WaitForSelectorAsync("input[title='Search']");5await page.TypeAsync("input[title='Search']", "PuppeteerSharp");6await page.Keyboard.PressAsync("Enter");7var events = new QueuedEventGroup(page);8await page.ClickAsync("a[href='

1using System;2using System.Threading.Tasks;3using PuppeteerSharp;4{5    {6        static async Task Main(string[] args)7        {8            var options = new LaunchOptions { Headless = false };9            using (var browser = await Puppeteer.LaunchAsync(options))10            using (var page = await browser.NewPageAsync())11            {12                var element = await page.QuerySelectorAsync("input[name='q']");13                await element.TypeAsync("Hello World");14                await page.ClickAsync("input[value='Google Search']");15                await page.WaitForNavigationAsync();