1

我有已经附加了文件存储流的 DataWriter。在特定情况下，我想先将数据写入内存，以便知道字节的大小，然后将大小与数据一起存储在写入器中。

如何在不创建两个内存缓冲区的情况下做到这一点？

DataWriter writer; // writer is parameter passed from somewhere else.

using (var inMemory = new InMemoryRandomAccessStream())
{
    // fill inMemory with data.

    // ***Here*** How can I avoid this?
    var buffer = new byte[checked((int)inMemory.Position)].AsBuffer();

    inMemory.Seek(0);
    await inMemory.ReadAsync(buffer, buffer.Length, InputStreamOptions.ReadAhead);

    writer.WriteUInt32(buffer.Length); // write size
    writer.WriteBuffer(buffer); // write data
}

如您所见，我使用了两个缓冲区，一个用于内存流，另一个用于 ibuffer。

我不知道如何将 inMemory 内容直接写入已附加文件存储流的 DataWriter 中。

4

1 回答 1

0

为了防止创建重复的缓冲区，我必须编写自己的缓冲区流。虽然流缓冲区在内部像列表一样工作，但是当列表变大时它有好处。

internal sealed class BufferStream : IDisposable
{
    private byte[] _array = Array.Empty<byte>();
    private int _index = -1;
    private const int MaxArrayLength = 0X7FEFFFFF;

    public int Capacity => _array.Length;
    public int Length => _index + 1;

    public void WriteIntoDataWriterStreamAsync(IDataWriter writer)
    {
        // AsBuffer wont cause copy, its just wrapper around array.
        if(_index >= 0) writer.WriteBuffer(_array.AsBuffer(0, _index)); 
    }

    public void WriteBuffer(IBuffer buffer)
    {
        EnsureSize(checked((int) buffer.Length));

        for (uint i = 0; i < buffer.Length; i++)
        {
            _array[++_index] = buffer.GetByte(i);
        }
    }

    public void Flush()
    {
        Array.Clear(_array, 0, _index);
        _index = -1;
    }

    // list like resizing.
    private void EnsureSize(int additionSize)
    {
        var min = additionSize + _index;
        if (_array.Length <= min)
        {
            var newsize = (int) Math.Min((uint) _array.Length * 2, MaxArrayLength);
            if (newsize <= min) newsize = min + 1;
            Array.Resize(ref _array, newsize);
        }
    }

    public void Dispose()
    {
        _array = null;
    }
}

然后我可以很容易地做到这一点。

using (var buffer = new BufferStream())
{
    // fill buffer

    writer.WriteInt32(buffer.Length); // write size
    buffer.WriteIntoDataWriterStream(writer); // write data
}
于 2017-09-27T13:36:12.557 回答