20 lines
566 B
C#
20 lines
566 B
C#
|
using System;
|
||
|
|
using System.Collections.Generic;
|
||
|
|
using System.IO;
|
||
|
|
using System.Reactive.Linq;
|
||
|
|
|
||
|
|
namespace MediaBrowser.Controller.Net
|
||
|
|
{
|
||
|
|
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;
|
||
|
|
})();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|