From 0a48b5e31aa712acd988626a88c52c47467945b2 Mon Sep 17 00:00:00 2001
From: LukePulverenti Luke Pulverenti luke pulverenti
 <LukePulverenti Luke Pulverenti luke.pulverenti@gmail.com>
Date: Sat, 21 Jul 2012 14:39:47 -0400
Subject: Added a BaseKernel for the UI and Server to share, and made some
 other minor re-organizations.

---
 MediaBrowser.Common/Net/StreamExtensions.cs | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)
 create mode 100644 MediaBrowser.Common/Net/StreamExtensions.cs

(limited to 'MediaBrowser.Common/Net/StreamExtensions.cs')

diff --git a/MediaBrowser.Common/Net/StreamExtensions.cs b/MediaBrowser.Common/Net/StreamExtensions.cs
new file mode 100644
index 0000000000..c10e458ada
--- /dev/null
+++ b/MediaBrowser.Common/Net/StreamExtensions.cs
@@ -0,0 +1,19 @@
+using System;
+using System.IO;
+using System.Reactive.Linq;
+
+namespace MediaBrowser.Common.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;
+            })();
+        }
+    }
+}
\ No newline at end of file
-- 
cgit v1.2.3