1 files changed, 40 insertions, 0 deletions
diff --git a/MediaBrowser.Common/Net/HttpServer.cs b/MediaBrowser.Common/Net/HttpServer.cs
new file mode 100644
index 000000000..276e14eb3
--- /dev/null
+++ b/MediaBrowser.Common/Net/HttpServer.cs
@@ -0,0 +1,40 @@
+using System;
+using System.Net;
+using System.Reactive.Linq;
+
+namespace MediaBrowser.Common.Net
+{
+    public class HttpServer : IObservable<HttpListenerContext>, IDisposable
+    {
+        private readonly HttpListener _listener;
+        private readonly IObservable<HttpListenerContext> _stream;
+
+        public HttpServer(string url)
+        {
+            _listener = new HttpListener();
+            _listener.Prefixes.Add(url);
+            _listener.Start();
+            _stream = ObservableHttpContext();
+        }
+
+        private IObservable<HttpListenerContext> ObservableHttpContext()
+        {
+            return Observable.Create<HttpListenerContext>(obs =>
+                                Observable.FromAsync(() => _listener.GetContextAsync())
+                                          .Subscribe(obs))
+                             .Repeat()
+                             .Retry()
+                             .Publish()
+                             .RefCount();
+        }
+        public void Dispose()
+        {
+            _listener.Stop();
+        }
+
+        public IDisposable Subscribe(IObserver<HttpListenerContext> observer)
+        {
+            return _stream.Subscribe(observer);
+        }
+    }
+}
+\ No newline at end of file