How to use DisposeAsync method of Microsoft.Playwright.Core.WritableStream class

1/*
2 * MIT License
3 *
4 * Copyright (c) Microsoft Corporation.
5 *
6 * Permission is hereby granted, free of charge, to any person obtaining a copy
7 * of this software and associated documentation files (the "Software"), to deal
8 * in the Software without restriction, including without limitation the rights
9 * to use, copy, modify, merge, publish, distribute, sublicense, and / or sell
10 * copies of the Software, and to permit persons to whom the Software is
11 * furnished to do so, subject to the following conditions:
12 *
13 * The above copyright notice and this permission notice shall be included in all
14 * copies or substantial portions of the Software.
15 *
16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
19 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
22 * SOFTWARE.
23 */
24
25using System;
26using System.IO;
27using System.Threading;
28using System.Threading.Tasks;
29using Microsoft.Playwright.Transport;
30using Microsoft.Playwright.Transport.Channels;
31
32namespace Microsoft.Playwright.Core
33{
34    internal class WritableStream : ChannelOwnerBase, IChannelOwner<WritableStream>, IAsyncDisposable
35    {
36        internal WritableStream(IChannelOwner parent, string guid) : base(parent, guid)
37        {
38            Channel = new(guid, parent.Connection, this);
39        }
40
41        ChannelBase IChannelOwner.Channel => Channel;
42
43        IChannel<WritableStream> IChannelOwner<WritableStream>.Channel => Channel;
44
45        public WritableStreamChannel Channel { get; }
46
47        public WritableStreamImpl WritableStreamImpl => new(this);
48
49        public Task WriteAsync(string binary) => Channel.WriteAsync(binary);
50
51        public ValueTask DisposeAsync() => new ValueTask(CloseAsync());
52
53        public Task CloseAsync() => Channel.CloseAsync();
54    }
55
56    internal class WritableStreamImpl : System.IO.Stream
57    {
58        private readonly WritableStream _stream;
59
60        internal WritableStreamImpl(WritableStream stream)
61        {
62            _stream = stream;
63        }
64
65        public override bool CanRead => throw new NotImplementedException();
66
67        public override bool CanSeek => throw new NotImplementedException();
68
69        public override bool CanWrite => true;
70
71        public override long Length => throw new NotImplementedException();
72
73        public override long Position { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
74
75        public override void Flush() => throw new NotImplementedException();
76
77        public override int Read(byte[] buffer, int offset, int count) => throw new NotImplementedException();
78
79        public override Task<int> ReadAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken) =>
80            throw new NotImplementedException();
81
82        public override void Close() => _stream.CloseAsync().ConfigureAwait(false);
83
84        public override long Seek(long offset, SeekOrigin origin) => throw new NotImplementedException();
85
86        public override void SetLength(long value) => throw new NotImplementedException();
87
88        public override void Write(byte[] buffer, int offset, int count) => throw new NotImplementedException();
89
90        public override async Task WriteAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
91        {
92            await this._stream.WriteAsync(Convert.ToBase64String(buffer)).ConfigureAwait(false);
93        }
94    }
95}
96

Source: WritableStream.cs

/*
 * MIT License
 *
 * Copyright (c) Microsoft Corporation.
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and / or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in all
 * copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 */

using System;
using System.IO;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Playwright.Transport;
using Microsoft.Playwright.Transport.Channels;

namespace Microsoft.Playwright.Core
{
    internal class WritableStream : ChannelOwnerBase, IChannelOwner<WritableStream>, IAsyncDisposable
    {
        internal WritableStream(IChannelOwner parent, string guid) : base(parent, guid)
        {
            Channel = new(guid, parent.Connection, this);
        }

        ChannelBase IChannelOwner.Channel => Channel;

        IChannel<WritableStream> IChannelOwner<WritableStream>.Channel => Channel;

        public WritableStreamChannel Channel { get; }

        public WritableStreamImpl WritableStreamImpl => new(this);

        public Task WriteAsync(string binary) => Channel.WriteAsync(binary);

        public ValueTask DisposeAsync() => new ValueTask(CloseAsync());

        public Task CloseAsync() => Channel.CloseAsync();
    }

    internal class WritableStreamImpl : System.IO.Stream
    {
        private readonly WritableStream _stream;

        internal WritableStreamImpl(WritableStream stream)
        {
            _stream = stream;
        }

        public override bool CanRead => throw new NotImplementedException();

        public override bool CanSeek => throw new NotImplementedException();

        public override bool CanWrite => true;

        public override long Length => throw new NotImplementedException();

        public override long Position { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }

        public override void Flush() => throw new NotImplementedException();

        public override int Read(byte[] buffer, int offset, int count) => throw new NotImplementedException();

        public override Task<int> ReadAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken) =>
            throw new NotImplementedException();

        public override void Close() => _stream.CloseAsync().ConfigureAwait(false);

        public override long Seek(long offset, SeekOrigin origin) => throw new NotImplementedException();

        public override void SetLength(long value) => throw new NotImplementedException();

        public override void Write(byte[] buffer, int offset, int count) => throw new NotImplementedException();

        public override async Task WriteAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
        {
            await this._stream.WriteAsync(Convert.ToBase64String(buffer)).ConfigureAwait(false);
        }
    }
}