private Task WriteToPipe()
{
    return Task.Run(() =>
    {
        int read = 0;
        do
        {
            read = await commandProcess.StandardOutput.BaseStream.Read(ReadBuffer, 0, ReadBuffer.Length);
            if (read != 0)
            {
                QueuePipe.Add((byte[])ReadBuffer.Clone(), cancelPipeToken.Token);
            }
        }
        while (read != 0);
    });
}