Merge pull request #1 from MediaBrowser/Repo

Repo

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