How to use SendAsync method of PuppeteerSharp.Transport.WebSocketTransport class

Best Puppeteer-sharp code snippet using PuppeteerSharp.Transport.WebSocketTransport.SendAsync

Connection.cs

Source:Connection.cs

...71        #region Public Methods72        internal int GetMessageID() => Interlocked.Increment(ref _lastId);73        internal Task RawSendASync(int id, string method, object args, string sessionId = null)74        {75            return Transport.SendAsync(JsonConvert.SerializeObject(76                new ConnectionRequest77                {78                    Id = id,79                    Method = method,80                    Params = args,81                    SessionId = sessionId82                },83                JsonHelper.DefaultJsonSerializerSettings));84        }85        internal async Task<JObject> SendAsync(string method, object args = null, bool waitForCallback = true)86        {87            if (IsClosed)88            {89                throw new TargetClosedException($"Protocol error({method}): Target closed.", CloseReason);90            }91            var id = GetMessageID();92            MessageTask callback = null;93            if (waitForCallback)94            {95                callback = new MessageTask96                {97                    TaskWrapper = new TaskCompletionSource<JObject>(),98                    Method = method99                };100                _callbacks[id] = callback;101            }102            await RawSendASync(id, method, args).ConfigureAwait(false);103            return waitForCallback ? await callback.TaskWrapper.Task.ConfigureAwait(false) : null;104        }105        internal async Task<T> SendAsync<T>(string method, object args = null)106        {107            var response = await SendAsync(method, args).ConfigureAwait(false);108            return response.ToObject<T>(true);109        }110        internal async Task<CDPSession> CreateSessionAsync(TargetInfo targetInfo)111        {112            var sessionId = (await SendAsync<TargetAttachToTargetResponse>("Target.attachToTarget", new TargetAttachToTargetRequest113            {114                TargetId = targetInfo.TargetId,115                Flatten = true116            }).ConfigureAwait(false)).SessionId;117            return await GetSessionAsync(sessionId).ConfigureAwait(false);118        }119        internal bool HasPendingCallbacks() => _callbacks.Count != 0;120        #endregion121        internal void Close(string closeReason)122        {123            if (IsClosed)124            {125                return;126            }...

LaunchOptions.cs

Source:LaunchOptions.cs

...143        /// The browser to be used (Chrome, Firefox)144        /// </summary>145        public Product Product { get; set; } = Product.Chrome;146        /// <summary>147        /// Affects how responses to <see cref="CDPSession.SendAsync"/> are returned to the caller. If <c>true</c> (default), the148        /// response is delivered to the caller on its own thread; otherwise, the response is delivered the same way <see cref="CDPSession.MessageReceived"/>149        /// events are raised.150        /// </summary>151        /// <remarks>152        /// This should normally be set to <c>true</c> to support applications that aren't <c>async</c> "all the way up"; i.e., the application153        /// has legacy code that is not async which makes calls into PuppeteerSharp. If you experience issues, or your application is not mixed sync/async use, you154        /// can set this to <c>false</c> (default).155        /// </remarks>156        public bool EnqueueAsyncMessages { get; set; }157        /// <summary>158        /// Callback to decide if Puppeteer should connect to a given target or not.159        /// </summary>160        public Func<TargetInfo, bool> TargetFilter { get; set; }161    }...

WebSocketTransport.cs

Source:WebSocketTransport.cs

...44        /// Sends a message using the transport.45        /// </summary>46        /// <returns>The task.</returns>47        /// <param name="message">Message to send.</param>48        public Task SendAsync(string message)49        {50            var encoded = Encoding.UTF8.GetBytes(message);51            var buffer = new ArraySegment<byte>(encoded, 0, encoded.Length);52            Task sendTask() => _client.SendAsync(buffer, WebSocketMessageType.Text, true, default);53            return _queueRequests ? _socketQueue.Enqueue(sendTask) : sendTask();54        }55        /// <summary>56        /// Stops reading incoming data.57        /// </summary>58        public void StopReading() => _readerCancellationSource.Cancel();59        /// <summary>60        /// Starts listening the socket61        /// </summary>62        /// <returns>The start.</returns>63        private async Task<object> GetResponseAsync()64        {65            var buffer = new byte[2048];66            //If it's not in the list we wait for it...

ConnectOptions.cs

Source:ConnectOptions.cs

...62        /// Setting this to <c>false</c> proved to work in .NET Core but it tends to fail on .NET Framework.63        /// </remarks>64        public bool EnqueueTransportMessages { get; set; } = true;65        /// <summary>66        /// Affects how responses to <see cref="CDPSession.SendAsync"/> are returned to the caller. If <c>true</c> (default), the67        /// response is delivered to the caller on its own thread; otherwise, the response is delivered the same way <see cref="CDPSession.MessageReceived"/>68        /// events are raised.69        /// </summary>70        /// <remarks>71        /// This should normally be set to <c>true</c> to support applications that aren't <c>async</c> "all the way up"; i.e., the application72        /// has legacy code that is not async which makes calls into PuppeteerSharp. If you experience issues, or your application is not mixed sync/async use, you73        /// can set this to <c>false</c> (default).74        /// </remarks>75        public bool EnqueueAsyncMessages { get; set; }76        /// <summary>77        /// Callback to decide if Puppeteer should connect to a given target or not.78        /// </summary>79        public Func<TargetInfo, bool> TargetFilter { get; set; }80        /// <summary>...

IConnectionOptions.cs

Source:IConnectionOptions.cs

...35        /// If not <see cref="Transport"/> is set this will be use to determine is the default <see cref="WebSocketTransport"/> will enqueue messages.36        /// </summary>37        bool EnqueueTransportMessages { get; set; }38        /// <summary>39        /// Affects how responses to <see cref="CDPSession.SendAsync"/> are returned to the caller.40        /// </summary>41        bool EnqueueAsyncMessages { get; set; }42        /// <summary>43        /// Callback to decide if Puppeteer should connect to a given target or not.44        /// </summary>45        public Func<TargetInfo, bool> TargetFilter { get; set; }46    }47}...

SendAsync

Using AI Code Generation

1using PuppeteerSharp;2using System;3using System.Threading.Tasks;4{5    {6        static async Task Main(string[] args)7        {8            var browser = await Puppeteer.LaunchAsync(new LaunchOptions9            {10                ExecutablePath = @"C:\Program Files (x86)\Google\Chrome\Application\chrome.exe",11            });12            var page = await browser.NewPageAsync();13            await page.ScreenshotAsync("google.png");14            await browser.CloseAsync();15        }16    }17}18using PuppeteerSharp;19using System;20using System.Threading.Tasks;21{22    {23        static async Task Main(string[] args)24        {25            var browser = await Puppeteer.LaunchAsync(new LaunchOptions26            {27                ExecutablePath = @"C:\Program Files (x86)\Google\Chrome\Application\chrome.exe",28            });29            var page = await browser.NewPageAsync();30            await page.ScreenshotAsync("google.png");31            await browser.CloseAsync();32        }33    }34}35using PuppeteerSharp;36using System;37using System.Threading.Tasks;38{39    {40        static async Task Main(string[] args)41        {42            var browser = await Puppeteer.LaunchAsync(new LaunchOptions43            {44                ExecutablePath = @"C:\Program Files (x86)\Google\Chrome\Application\chrome.exe",45            });46            var page = await browser.NewPageAsync();47            await page.ScreenshotAsync("google.png");48            await browser.CloseAsync();49        }50    }51}52using PuppeteerSharp;

SendAsync

Using AI Code Generation

1using System;2using System.Threading.Tasks;3using PuppeteerSharp;4{5    {6        static async Task Main(string[] args)7        {8            var browserFetcher = new BrowserFetcher(new BrowserFetcherOptions9            {10            });11            await browserFetcher.DownloadAsync(BrowserFetcher.DefaultRevision);12            var browser = await Puppeteer.LaunchAsync(new LaunchOptions13            {14            });15            var page = await browser.NewPageAsync();16            await page.ScreenshotAsync("google.png");17            await browser.CloseAsync();18        }19    }20}

SendAsync

Using AI Code Generation

1using System;2using System.Net.WebSockets;3using System.Threading;4using System.Threading.Tasks;5using PuppeteerSharp;6using PuppeteerSharp.Transport;7using WebSocketSharp;8{9    {10        static async Task Main(string[] args)11        {12            var browser = await Puppeteer.LaunchAsync(new LaunchOptions13            {14            });15            var page = await browser.NewPageAsync();16            await page.ScreenshotAsync("google.png");17            await browser.CloseAsync();18        }19    }20}21Unhandled Exception: System.InvalidOperationException: The WebSocket is in an invalid state ('Aborted') for this operation. Valid states are: 'Open, CloseReceived, CloseSent'22   at System.Net.WebSockets.ManagedWebSocket.ThrowIfInvalidState(ManagedWebSocketState currentState, Boolean isDisposed, Boolean isAborted, Boolean allowClosed)23   at System.Net.WebSockets.ManagedWebSocket.SendAsyncPrivate[TWebSocketReceiveResultGetter,TWebSocketReceiveResult](ReadOnlyMemory`1 buffer, WebSocketMessageType messageType, Boolean endOfMessage, CancellationToken cancellationToken)24   at PuppeteerSharp.Transport.WebSocketTransport.SendAsync(String message, CancellationToken cancellationToken) in C:\projects\puppeteer-sharp\lib\PuppeteerSharp\Transport\WebSocketTransport.cs:line 6925   at PuppeteerSharp.Connection.SendAsync[T](String method, Object args, Boolean waitForCallback, CancellationToken cancellationToken) in C:\projects\puppeteer-sharp\lib\PuppeteerSharp\Connection.cs:line 21626   at PuppeteerSharp.Connection.SendAsync[T](String method, Object args, CancellationToken cancellationToken) in C:\projects\puppeteer-sharp\lib\PuppeteerSharp\Connection.cs:line 19427   at PuppeteerSharp.Page.ScreenshotDataAsync(ScreenshotOptions options, CancellationToken cancellationToken) in C:\projects\puppeteer-sharp\lib\PuppeteerSharp\Page.cs:line 116228   at PuppeteerSharp.Page.ScreenshotAsync(String path, ScreenshotOptions options, CancellationToken cancellationToken) in C:\projects\puppeteer-sharp\lib\PuppeteerSharp\Page.cs:line 114729   at PuppeteerSharp.Page.ScreenshotAsync(String path, CancellationToken cancellationToken) in C:\projects\puppeteer-sh

SendAsync

Using AI Code Generation

1await transport.SendAsync("Runtime.evaluate", "{\"expression\":\"document.querySelector('input[type=\"submit\"]').click()\"}");2await transport.CloseAsync();3await transport.SendAsync("Runtime.evaluate", "{\"expression\":\"document.querySelector('input[type=\"submit\"]').click()\"}");4await transport.CloseAsync();5await transport.SendAsync("Runtime.evaluate", "{\"expression\":\"document.querySelector('input[type=\"submit\"]').click()\"}");6await transport.CloseAsync();7await transport.SendAsync("Runtime.evaluate", "{\"expression\":\"document.querySelector('input[type=\"submit\"]').click()\"}");8await transport.CloseAsync();9await transport.SendAsync("Runtime.evaluate", "{\"expression\":\"document.querySelector('input[type=\"submit\"]').click()\"}");10await transport.CloseAsync();

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.