How to use WritableStream class of Microsoft.Playwright.Core package

...494                ["strict"] = strict,495            };496            return Connection.SendMessageToServerAsync(Guid, "setInputFiles", args);497        }498        internal Task SetInputFilePathsAsync(string selector, IEnumerable<string> localPaths, IEnumerable<WritableStream> streams, bool? noWaitAfter, float? timeout, bool? strict)499        {500            var args = new Dictionary<string, object>501            {502                ["selector"] = selector,503                ["localPaths"] = localPaths,504                ["streams"] = streams,505                ["timeout"] = timeout,506                ["noWaitAfter"] = noWaitAfter,507                ["strict"] = strict,508            };509            return Connection.SendMessageToServerAsync(Guid, "setInputFilePaths", args);510        }511        internal async Task<string> TextContentAsync(string selector, float? timeout, bool? strict)512        {...

...54            DefaultJsonSerializerOptions.Converters.Add(new ChannelOwnerToGuidConverter<JSHandle>(this));55            DefaultJsonSerializerOptions.Converters.Add(new ChannelOwnerToGuidConverter<ElementHandle>(this));56            DefaultJsonSerializerOptions.Converters.Add(new ChannelOwnerToGuidConverter<IChannelOwner>(this));57            // Workaround for https://github.com/dotnet/runtime/issues/4652258            DefaultJsonSerializerOptions.Converters.Add(new ChannelOwnerListToGuidListConverter<WritableStream>(this));59        }60        /// <inheritdoc cref="IDisposable.Dispose"/>61        ~Connection() => Dispose(false);62        internal event EventHandler<string> Close;63        public ConcurrentDictionary<string, IChannelOwner> Objects { get; } = new();64        internal AsyncLocal<List<ApiZone>> ApiZone { get; } = new();65        public bool IsClosed { get; private set; }66        internal bool IsRemote { get; set; }67        internal Func<object, Task> OnMessage { get; set; }68        internal JsonSerializerOptions DefaultJsonSerializerOptions { get; }69        public void Dispose()70        {71            Dispose(true);72            GC.SuppressFinalize(this);73        }74        internal Task<JsonElement?> SendMessageToServerAsync(75            string guid,76            string method,77            object args = null)78            => SendMessageToServerAsync<JsonElement?>(guid, method, args);79        internal Task<T> SendMessageToServerAsync<T>(80            string guid,81            string method,82            object args = null) => WrapApiCallAsync(() => InnerSendMessageToServerAsync<T>(guid, method, args));83        private async Task<T> InnerSendMessageToServerAsync<T>(84            string guid,85            string method,86            object args = null)87        {88            if (IsClosed)89            {90                throw new PlaywrightException($"Connection closed ({_reason})");91            }92            int id = Interlocked.Increment(ref _lastId);93            var tcs = new TaskCompletionSource<JsonElement?>(TaskCreationOptions.RunContinuationsAsynchronously);94            var callback = new ConnectionCallback95            {96                TaskCompletionSource = tcs,97            };98            _callbacks.TryAdd(id, callback);99            var sanitizedArgs = new Dictionary<string, object>();100            if (args != null)101            {102                if (args is IDictionary<string, object> dictionary && dictionary.Keys.Any(f => f != null))103                {104                    foreach (var kv in dictionary)105                    {106                        if (kv.Value != null)107                        {108                            sanitizedArgs.Add(kv.Key, kv.Value);109                        }110                    }111                }112                else113                {114                    foreach (PropertyDescriptor propertyDescriptor in TypeDescriptor.GetProperties(args))115                    {116                        object obj = propertyDescriptor.GetValue(args);117                        if (obj != null)118                        {119#pragma warning disable CA1845 // Use span-based 'string.Concat' and 'AsSpan' instead of 'Substring120                            string name = propertyDescriptor.Name.Substring(0, 1).ToLower() + propertyDescriptor.Name.Substring(1);121#pragma warning restore CA2000 // Use span-based 'string.Concat' and 'AsSpan' instead of 'Substring122                            sanitizedArgs.Add(name, obj);123                        }124                    }125                }126            }127            await _queue.EnqueueAsync(() =>128            {129                var message = new MessageRequest130                {131                    Id = id,132                    Guid = guid,133                    Method = method,134                    Params = sanitizedArgs,135                    Metadata = ApiZone.Value[0],136                };137                TraceMessage("pw:channel:command", message);138                return OnMessage(message);139            }).ConfigureAwait(false);140            var result = await tcs.Task.ConfigureAwait(false);141            if (typeof(T) == typeof(JsonElement?))142            {143                return (T)(object)result?.Clone();144            }145            else if (result == null)146            {147                return default;148            }149            else if (typeof(ChannelBase).IsAssignableFrom(typeof(T)) || typeof(ChannelBase[]).IsAssignableFrom(typeof(T)))150            {151                var enumerate = result.Value.EnumerateObject();152                return enumerate.Any()153                    ? enumerate.FirstOrDefault().Value.ToObject<T>(DefaultJsonSerializerOptions)154                    : default;155            }156            else157            {158                return result.Value.ToObject<T>(DefaultJsonSerializerOptions);159            }160        }161        internal IChannelOwner GetObject(string guid)162        {163            Objects.TryGetValue(guid, out var result);164            return result;165        }166        internal void MarkAsRemote() => IsRemote = true;167        internal Task<PlaywrightImpl> InitializePlaywrightAsync()168        {169            return _rootObject.InitializeAsync();170        }171        internal void OnObjectCreated(string guid, IChannelOwner result)172        {173            Objects.TryAdd(guid, result);174        }175        internal void Dispatch(PlaywrightServerMessage message)176        {177            if (message.Id.HasValue)178            {179                TraceMessage("pw:channel:response", message);180                if (_callbacks.TryRemove(message.Id.Value, out var callback))181                {182                    if (message.Error != null)183                    {184                        callback.TaskCompletionSource.TrySetException(CreateException(message.Error.Error));185                    }186                    else187                    {188                        callback.TaskCompletionSource.TrySetResult(message.Result);189                    }190                }191                return;192            }193            TraceMessage("pw:channel:event", message);194            try195            {196                if (message.Method == "__create__")197                {198                    var createObjectInfo = message.Params.Value.ToObject<CreateObjectInfo>(DefaultJsonSerializerOptions);199                    CreateRemoteObject(message.Guid, createObjectInfo.Type, createObjectInfo.Guid, createObjectInfo.Initializer);200                    return;201                }202                if (message.Method == "__dispose__")203                {204                    Objects.TryGetValue(message.Guid, out var disableObject);205                    disableObject?.DisposeOwner();206                    return;207                }208                Objects.TryGetValue(message.Guid, out var obj);209                obj?.Channel?.OnMessage(message.Method, message.Params);210            }211            catch (Exception ex)212            {213                DoClose(ex);214            }215        }216        private void CreateRemoteObject(string parentGuid, ChannelOwnerType type, string guid, JsonElement? initializer)217        {218            IChannelOwner result = null;219            var parent = string.IsNullOrEmpty(parentGuid) ? _rootObject : Objects[parentGuid];220#pragma warning disable CA2000 // Dispose objects before losing scope221            switch (type)222            {223                case ChannelOwnerType.Artifact:224                    result = new Artifact(parent, guid, initializer?.ToObject<ArtifactInitializer>(DefaultJsonSerializerOptions));225                    break;226                case ChannelOwnerType.BindingCall:227                    result = new BindingCall(parent, guid, initializer?.ToObject<BindingCallInitializer>(DefaultJsonSerializerOptions));228                    break;229                case ChannelOwnerType.Playwright:230                    result = new PlaywrightImpl(parent, guid, initializer?.ToObject<PlaywrightInitializer>(DefaultJsonSerializerOptions));231                    break;232                case ChannelOwnerType.Browser:233                    var browserInitializer = initializer?.ToObject<BrowserInitializer>(DefaultJsonSerializerOptions);234                    result = new Browser(parent, guid, browserInitializer);235                    break;236                case ChannelOwnerType.BrowserType:237                    var browserTypeInitializer = initializer?.ToObject<BrowserTypeInitializer>(DefaultJsonSerializerOptions);238                    result = new Core.BrowserType(parent, guid, browserTypeInitializer);239                    break;240                case ChannelOwnerType.BrowserContext:241                    var browserContextInitializer = initializer?.ToObject<BrowserContextInitializer>(DefaultJsonSerializerOptions);242                    result = new BrowserContext(parent, guid, browserContextInitializer);243                    break;244                case ChannelOwnerType.ConsoleMessage:245                    result = new ConsoleMessage(parent, guid, initializer?.ToObject<ConsoleMessageInitializer>(DefaultJsonSerializerOptions));246                    break;247                case ChannelOwnerType.Dialog:248                    result = new Dialog(parent, guid, initializer?.ToObject<DialogInitializer>(DefaultJsonSerializerOptions));249                    break;250                case ChannelOwnerType.ElementHandle:251                    result = new ElementHandle(parent, guid, initializer?.ToObject<ElementHandleInitializer>(DefaultJsonSerializerOptions));252                    break;253                case ChannelOwnerType.Frame:254                    result = new Frame(parent, guid, initializer?.ToObject<FrameInitializer>(DefaultJsonSerializerOptions));255                    break;256                case ChannelOwnerType.JSHandle:257                    result = new JSHandle(parent, guid, initializer?.ToObject<JSHandleInitializer>(DefaultJsonSerializerOptions));258                    break;259                case ChannelOwnerType.JsonPipe:260                    result = new JsonPipe(parent, guid, initializer?.ToObject<JsonPipeInitializer>(DefaultJsonSerializerOptions));261                    break;262                case ChannelOwnerType.LocalUtils:263                    result = new LocalUtils(parent, guid, initializer);264                    break;265                case ChannelOwnerType.Page:266                    result = new Page(parent, guid, initializer?.ToObject<PageInitializer>(DefaultJsonSerializerOptions));267                    break;268                case ChannelOwnerType.Request:269                    result = new Request(parent, guid, initializer?.ToObject<RequestInitializer>(DefaultJsonSerializerOptions));270                    break;271                case ChannelOwnerType.Response:272                    result = new Response(parent, guid, initializer?.ToObject<ResponseInitializer>(DefaultJsonSerializerOptions));273                    break;274                case ChannelOwnerType.Route:275                    result = new Route(parent, guid, initializer?.ToObject<RouteInitializer>(DefaultJsonSerializerOptions));276                    break;277                case ChannelOwnerType.Worker:278                    result = new Worker(parent, guid, initializer?.ToObject<WorkerInitializer>(DefaultJsonSerializerOptions));279                    break;280                case ChannelOwnerType.WebSocket:281                    result = new WebSocket(parent, guid, initializer?.ToObject<WebSocketInitializer>(DefaultJsonSerializerOptions));282                    break;283                case ChannelOwnerType.Selectors:284                    result = new Selectors(parent, guid);285                    break;286                case ChannelOwnerType.SocksSupport:287                    result = new SocksSupport(parent, guid);288                    break;289                case ChannelOwnerType.Stream:290                    result = new Stream(parent, guid);291                    break;292                case ChannelOwnerType.WritableStream:293                    result = new WritableStream(parent, guid);294                    break;295                case ChannelOwnerType.Tracing:296                    result = new Tracing(parent, guid);297                    break;298                default:299                    TraceMessage("pw:dotnet", "Missing type " + type);300                    break;301            }302#pragma warning restore CA2000303            Objects.TryAdd(guid, result);304            OnObjectCreated(guid, result);305        }306        private void DoClose(Exception ex)307        {...

...245                ["noWaitAfter"] = noWaitAfter,246            };247            return Connection.SendMessageToServerAsync(Guid, "setInputFiles", args);248        }249        internal Task SetInputFilePathsAsync(IEnumerable<string> localPaths, IEnumerable<WritableStream> streams, bool? noWaitAfter, float? timeout)250        {251            var args = new Dictionary<string, object>252            {253                ["localPaths"] = localPaths,254                ["streams"] = streams,255                ["timeout"] = timeout,256                ["noWaitAfter"] = noWaitAfter,257            };258            return Connection.SendMessageToServerAsync(Guid, "setInputFilePaths", args);259        }260        internal async Task<string> GetAttributeAsync(string name)261        {262            var args = new Dictionary<string, object>263            {...

...207            Guid,208            "harExport").ConfigureAwait(false);209            return result.GetObject<Artifact>("artifact", Connection);210        }211        internal async Task<WritableStream> CreateTempFileAsync(string name)212        {213            var channelArgs = new Dictionary<string, object>214            {215                { "name", name },216            };217            var result = await Connection.SendMessageToServerAsync(Guid, "createTempFile", channelArgs).ConfigureAwait(false);218            return result.GetObject<WritableStream>("writableStream", Connection);219        }220    }221}...

...28using Microsoft.Playwright.Transport;29using Microsoft.Playwright.Transport.Channels;30namespace Microsoft.Playwright.Core31{32    internal class WritableStream : ChannelOwnerBase, IChannelOwner<WritableStream>, IAsyncDisposable33    {34        internal WritableStream(IChannelOwner parent, string guid) : base(parent, guid)35        {36            Channel = new(guid, parent.Connection, this);37        }38        ChannelBase IChannelOwner.Channel => Channel;39        IChannel<WritableStream> IChannelOwner<WritableStream>.Channel => Channel;40        public WritableStreamChannel Channel { get; }41        public WritableStreamImpl WritableStreamImpl => new(this);42        public Task WriteAsync(string binary) => Channel.WriteAsync(binary);43        public ValueTask DisposeAsync() => new ValueTask(CloseAsync());44        public Task CloseAsync() => Channel.CloseAsync();45    }46    internal class WritableStreamImpl : System.IO.Stream47    {48        private readonly WritableStream _stream;49        internal WritableStreamImpl(WritableStream stream)50        {51            _stream = stream;52        }53        public override bool CanRead => throw new NotImplementedException();54        public override bool CanSeek => throw new NotImplementedException();55        public override bool CanWrite => true;56        public override long Length => throw new NotImplementedException();57        public override long Position { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }58        public override void Flush() => throw new NotImplementedException();59        public override int Read(byte[] buffer, int offset, int count) => throw new NotImplementedException();60        public override Task<int> ReadAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken) =>61            throw new NotImplementedException();62        public override void Close() => _stream.CloseAsync().ConfigureAwait(false);63        public override long Seek(long offset, SeekOrigin origin) => throw new NotImplementedException();...

...25using System.Threading.Tasks;26using Microsoft.Playwright.Core;27namespace Microsoft.Playwright.Transport.Channels28{29    internal class WritableStreamChannel : Channel<WritableStream>30    {31        public WritableStreamChannel(string guid, Connection connection, WritableStream owner) : base(guid, connection, owner)32        {33        }34        internal async Task WriteAsync(string binary)35        {36            await Connection.SendMessageToServerAsync(37                Guid,38                "write",39                new Dictionary<string, object>40                {41                    ["binary"] = binary,42                }).ConfigureAwait(false);43        }44        internal Task CloseAsync() => Connection.SendMessageToServerAsync(Guid, "close", null);45    }...

...28    internal class SetInputFilesFiles29    {30        public IEnumerable<InputFilesList> Files { get; set; }31        public string[] LocalPaths { get; set; }32        public WritableStream[] Streams { get; set; }33    }34}...

1using System;2using System.IO;3using System.Threading.Tasks;4using Microsoft.Playwright;5{6    {7        static async Task Main(string[] args)8        {9            await using var playwright = await Playwright.CreateAsync();10            await using var browser = await playwright.Chromium.LaunchAsync(new BrowserTypeLaunchOptions11            {12            });13            var page = await browser.NewPageAsync();14            var screenshot = await page.ScreenshotAsync();15            var stream = new WritableStream();16            await screenshot.SaveAsAsync(stream, "png");17            await stream.CloseAsync();18            using (FileStream file = new FileStream("screenshot.png", FileMode.Create, System.IO.FileAccess.Write))19            {20                stream.CopyTo(file);21            }22        }23    }24}

1using Microsoft.Playwright;2using System;3using System.Threading.Tasks;4{5    {6        static async Task Main(string[] args)7        {8            using var playwright = await Playwright.CreateAsync();9            await using var browser = await playwright.Chromium.LaunchAsync();10            var page = await browser.NewPageAsync();11            await page.PdfAsync("google.pdf");12        }13    }14}

1using Microsoft.Playwright.Core;2using System;3using System.Threading.Tasks;4{5    {6        static async Task Main(string[] args)7        {8            var playwright = await Playwright.CreateAsync();9            var browser = await playwright.Firefox.LaunchAsync();10            var page = await browser.NewPageAsync();11            var stream = new WritableStream();12            await page.ScreenshotAsync(stream: stream);13            await browser.CloseAsync();14        }15    }16}17using Microsoft.Playwright;18using System;19using System.Threading.Tasks;20{21    {22        static async Task Main(string[] args)23        {24            var playwright = await Playwright.CreateAsync();25            var browser = await playwright.Firefox.LaunchAsync();26            var page = await browser.NewPageAsync();27            var stream = new WritableStream();28            await page.ScreenshotAsync(stream: stream);29            await browser.CloseAsync();30        }31    }32}33using System;34using System.IO.Pipelines;35using System.Threading.Tasks;36{37    {38        static async Task Main(string[] args)39        {40            var playwright = await Microsoft.Playwright.Core.Playwright.CreateAsync();41            var browser = await playwright.Firefox.LaunchAsync();42            var page = await browser.NewPageAsync();43            var stream = new WritableStream();44            await page.ScreenshotAsync(stream: stream);45            await browser.CloseAsync();46        }47    }48}

1using Microsoft.Playwright;2using System;3using System.Threading.Tasks;4{5    {6        static async Task Main(string[] args)7        {8            using var playwright = await Playwright.CreateAsync();9            var browser = await playwright.Chromium.LaunchAsync(new BrowserTypeLaunchOptions10            {11            });12            var context = await browser.NewContextAsync();13            var page = await context.NewPageAsync();14            var ws = page.Context.GetWebSocketEndpoint();15            var stream = new WritableStream();16            stream.OnWrite += (data) =>17            {18                Console.WriteLine(data);19            };20            await page.Context.ExposeBindingAsync("write", stream.WriteAsync);21            await page.EvaluateAsync("() => write('Hello World!')");22            await browser.CloseAsync();23        }24    }25}26using Microsoft.Playwright;27using System;28using System.Threading.Tasks;29{30    {31        static async Task Main(string[] args)32        {33            using var playwright = await Playwright.CreateAsync();34            var browser = await playwright.Chromium.LaunchAsync(new BrowserTypeLaunchOptions35            {36            });37            var context = await browser.NewContextAsync();38            var page = await context.NewPageAsync();39            var ws = page.Context.GetWebSocketEndpoint();40            var stream = new WritableStream();41            stream.OnWrite += (data) =>42            {43                Console.WriteLine(data);44            };45            await page.Context.ExposeBindingAsync("write", stream.WriteAsync);46            await page.EvaluateAsync("() => write('Hello World!')");47            await browser.CloseAsync();48        }49    }50}51using Microsoft.Playwright;52using System;53using System.Threading.Tasks;54{55    {56        static async Task Main(string[] args)57        {58            using var playwright = await Playwright.CreateAsync();59            var browser = await playwright.Chromium.LaunchAsync(new BrowserTypeLaunchOptions60            {61            });62            var context = await browser.NewContextAsync();

1using System;2using System.Threading.Tasks;3using Microsoft.Playwright;4using System.IO;5{6    {7        static async Task Main(string[] args)8        {9            using var playwright = await Playwright.CreateAsync();10            var browser = await playwright.Chromium.LaunchAsync(new BrowserTypeLaunchOptions11            {12            });13            var context = await browser.NewContextAsync();14            var page = await context.NewPageAsync();15            await page.ScreenshotAsync(new PageScreenshotOptions16            {17            });18            await browser.CloseAsync();19        }20    }21}22using System;23using System.Threading.Tasks;24using Microsoft.Playwright;25using System.IO;26{27    {28        static async Task Main(string[] args)29        {30            using var playwright = await Playwright.CreateAsync();31            var browser = await playwright.Chromium.LaunchAsync(new BrowserTypeLaunchOptions32            {33            });34            var context = await browser.NewContextAsync();35            var page = await context.NewPageAsync();36            await page.ScreenshotAsync(new PageScreenshotOptions37            {38            });39            await browser.CloseAsync();40        }41    }42}43   at Microsoft.Playwright.Core.Page.ScreenshotAsync(PageScreenshotOptions options, Boolean isAsync)44   at Microsoft.Playwright.Core.Page.ScreenshotAsync(PageScreenshotOptions options)45   at PlaywrightTest.Program.Main(String[] args) in C:\Users\username\source\repos\PlaywrightTest\PlaywrightTest\Program.cs:line 24

1using Microsoft.Playwright.Core;2using System;3using System.IO;4using System.Threading.Tasks;5{6    {7        static async Task Main(string[] args)8        {9            var playwright = await Playwright.CreateAsync();10            var browser = await playwright.Chromium.LaunchAsync(new LaunchOptions11            {12            });13            var context = await browser.NewContextAsync();14            var page = await context.NewPageAsync();15            var stream = new MemoryStream();16            await response.Body.CopyToAsync(stream);17            await page.ScreenshotAsync(new PageScreenshotOptions18            {19            });20            await browser.CloseAsync();21            await playwright.StopAsync();22        }23    }24}25var stream = new WritableStream();

1using System;2using System.IO;3using System.Threading.Tasks;4using Microsoft.Playwright;5using Microsoft.Playwright.Core;6using Microsoft.Playwright.Transport.Channels;7{8    {9        static async Task Main(string[] args)10        {11            using var playwright = await Playwright.CreateAsync();12            await using var browser = await playwright.Chromium.LaunchAsync();13            var page = await browser.NewPageAsync();14            var content = await page.GetContentAsync();15            var file = new WritableStream(new FileStream("microsoft.html", FileMode.Create));16            await file.WriteAsync(content);17            await file.CloseAsync();18        }19    }20}21using System;22using System.IO;23using System.Threading.Tasks;24using Microsoft.Playwright;25{26    {27        static async Task Main(string[] args)28        {29            using var playwright = await Playwright.CreateAsync();30            await using var browser = await playwright.Chromium.LaunchAsync();31            var page = await browser.NewPageAsync();32            var content = await page.GetContentAsync();33            var file = new WritableStream(new FileStream("microsoft.html", FileMode.Create));34            await file.WriteAsync(content);35            await file.CloseAsync();36        }37    }38}39using System;40using System.IO;41using System.Threading.Tasks;42using Microsoft.Playwright.Transport.Channels;43{44    {45        static async Task Main(string[] args)46        {

1using System;2using System.Threading.Tasks;3using Microsoft.Playwright;4using Microsoft.Playwright.Core;5using Microsoft.Playwright.Helpers;6{7    {8        static async Task Main(string[] args)9        {10            await using var playwright = await Playwright.CreateAsync();11            await using var browser = await playwright.Chromium.LaunchAsync();12            var page = await browser.NewPageAsync();13            var elementHandle = await page.QuerySelectorAsync("text=Get Started");14            await elementHandle.ClickAsync();15            var handle = await page.QuerySelectorAsync("text=Playwright is a Node library to automate Chromium, Firefox and WebKit with a single API.");16            var stream = new WritableStream();17            await handle.ScreenshotAsync(new PageScreenshotOptions { Stream = stream });18            await stream.DisposeAsync();19            await page.CloseAsync();20            await browser.CloseAsync();21        }22    }23}24using System;25using System.Threading.Tasks;26using Microsoft.Playwright;27using Microsoft.Playwright.Core;28using Microsoft.Playwright.Helpers;29using System.IO.Pipelines;30{31    {32        static async Task Main(string[] args)33        {34            await using var playwright = await Playwright.CreateAsync();35            await using var browser = await playwright.Chromium.LaunchAsync();36            var page = await browser.NewPageAsync();37            var elementHandle = await page.QuerySelectorAsync("text=Get Started");38            await elementHandle.ClickAsync();39            var handle = await page.QuerySelectorAsync("text=Playwright is a Node library to automate Chromium, Firefox and WebKit with a single API.");40            var stream = new WritableStream();41            await handle.ScreenshotAsync(new PageScreenshotOptions { Stream = stream });42            await stream.DisposeAsync();43            await page.CloseAsync();44            await browser.CloseAsync();45        }46    }47}48using System;49using System.Threading.Tasks;50using Microsoft.Playwright;51using Microsoft.Playwright.Core;52using Microsoft.Playwright.Helpers;53using System.IO.Pipelines;54{