我想在C#中实现一个IRandomAccessstream实例(它将返回实时生成的数据).该流实际上不需要是可写的或可搜索的,但我想在ReadAsync方法中返回我自己的数据(它实际上是IInputStream的一部分).
public IAsyncoperationWithProgress<IBuffer,uint> ReadAsync(IBuffer buffer,uint count,InputStreamOptions options)
{
throw new NotImplementedException("To be done");
}
我的两个主要问题是：
>如何返回实现IAsyncoperationWithProgress的内容？框架中是否有任何内容可以帮助解决这个问题？
>如何将数据写入缓冲区？ IBuffer只有Length和Capacity属性(具体的Buffer类也不再提供).
解决方法
How to Convert byte Array to IRandomAccessStream
我发现这篇博客文章,希望这个IRandomAccessstream的实现可以成为你的起点.
class MemoryRandomAccessstream : IRandomAccessstream
{
private Stream m_InternalStream;
public MemoryRandomAccessstream(Stream stream)
{
this.m_InternalStream = stream;
}
public MemoryRandomAccessstream(byte[] bytes)
{
this.m_InternalStream = new MemoryStream(bytes);
}
public IInputStream GetInputStreamAt(ulong position)
{
this.m_InternalStream.Seek((long)position,SeekOrigin.Begin);
return this.m_InternalStream.AsInputStream();
}
public IoUtputStream GetoutputStreamAt(ulong position)
{
this.m_InternalStream.Seek((long)position,SeekOrigin.Begin);
return this.m_InternalStream.AsOutputStream();
}
public ulong Size
{
get { return (ulong)this.m_InternalStream.Length; }
set { this.m_InternalStream.SetLength((long)value); }
}
public bool CanRead
{
get { return true; }
}
public bool CanWrite
{
get { return true; }
}
public IRandomAccessstream Clonestream()
{
throw new NotSupportedException();
}
public ulong Position
{
get { return (ulong)this.m_InternalStream.Position; }
}
public void Seek(ulong position)
{
this.m_InternalStream.Seek((long)position,0);
}
public void dispose()
{
this.m_InternalStream.dispose();
}
public Windows.Foundation.IAsyncoperationWithProgress<IBuffer,InputStreamOptions options)
{
var inputStream = this.GetInputStreamAt(0);
return inputStream.ReadAsync(buffer,count,options);
}
public Windows.Foundation.IAsyncoperation<bool> FlushAsync()
{
var outputStream = this.GetoutputStreamAt(0);
return outputStream.FlushAsync();
}
public Windows.Foundation.IAsyncoperationWithProgress<uint,uint> WriteAsync(IBuffer buffer)
{
var outputStream = this.GetoutputStreamAt(0);
return outputStream.WriteAsync(buffer);
}
}