jellyfin-server/MediaBrowser.Net/StreamExtensions.cs

19 lines
520 B
C#
Raw Normal View History

2012-07-12 06:55:27 +00:00
using System;
using System.IO;
using System.Reactive.Linq;
namespace MediaBrowser.Net
2012-07-12 06:55:27 +00:00
{
public static class StreamExtensions
{
public static IObservable<byte[]> ReadBytes(this Stream stream, int count)
{
var buffer = new byte[count];
return Observable.FromAsyncPattern((cb, state) => stream.BeginRead(buffer, 0, count, cb, state), ar =>
{
stream.EndRead(ar);
return buffer;
})();
}
}
}