using System;

using System.IO.Pipelines;

using System.IO.Pipes;

using System.Threading.Tasks;

using System.Buffers;

public class Program

{

    public static byte[] GetByteArray(int numBytes)

    {

        Random rnd = new Random();

        byte[] b = new byte[numBytes]; 

        rnd.NextBytes(b);

        return b;

    }

    public static async Task Main()

    {

        int count = 0;

        Pipe pipe = new Pipe();

        byte[] buffer = GetByteArray(10);

        Task readerTask = Task.Factory.StartNew(async () => {

            int count = 0;

            while(count < 20)

            {

                // ReadResult result = await pipe.Reader.ReadAsync();

                // Console.WriteLine($"reader iteration {count} with finished status: {result.IsCompleted} and buffer length: {result.Buffer.Length}");

                // byte[] buffer = result.Buffer.ToArray();

                // pipe.Reader.AdvanceTo(result.Buffer.End);

                count++;

                // if (result.IsCompleted) break;

            }

            Console.WriteLine("reader end reached");

        });

        while(count < 1000) {

            Console.WriteLine($"writer iteration --> {count}");

            await pipe.Writer.WriteAsync(buffer);

            // Console.WriteLine(pipe.Writer.UnflushedBytes);

            buffer = GetByteArray(10);

            count++;

            // await Task.Delay(1000);

        }

        await pipe.Writer.CompleteAsync();

        await Task.Delay(20 * 1000);

    }

}