aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Common/Net/HttpServer.cs
diff options
context:
space:
mode:
authorLukePulverenti Luke Pulverenti luke pulverenti <LukePulverenti Luke Pulverenti luke.pulverenti@gmail.com>2012-08-10 09:07:58 -0400
committerLukePulverenti Luke Pulverenti luke pulverenti <LukePulverenti Luke Pulverenti luke.pulverenti@gmail.com>2012-08-10 09:07:58 -0400
commit2536011247de55c75e8b1f893e23b606e4200159 (patch)
treef0cfa3893da3eedea162b651355088d068ade0ef /MediaBrowser.Common/Net/HttpServer.cs
parentdce7706382aaacae5ee74ba5048b76269e5390e5 (diff)
Added the ability for the server to handle byte-range requests, and also added a static file handler to utilize it
Diffstat (limited to 'MediaBrowser.Common/Net/HttpServer.cs')
-rw-r--r--MediaBrowser.Common/Net/HttpServer.cs11
1 files changed, 5 insertions, 6 deletions
diff --git a/MediaBrowser.Common/Net/HttpServer.cs b/MediaBrowser.Common/Net/HttpServer.cs
index fad8d13eb..9acccbf2d 100644
--- a/MediaBrowser.Common/Net/HttpServer.cs
+++ b/MediaBrowser.Common/Net/HttpServer.cs
@@ -4,10 +4,10 @@ using System.Reactive.Linq;
namespace MediaBrowser.Common.Net
{
- public class HttpServer : IObservable<RequestContext>, IDisposable
+ public class HttpServer : IObservable<HttpListenerContext>, IDisposable
{
private readonly HttpListener listener;
- private readonly IObservable<RequestContext> stream;
+ private readonly IObservable<HttpListenerContext> stream;
public HttpServer(string url)
{
@@ -17,12 +17,11 @@ namespace MediaBrowser.Common.Net
stream = ObservableHttpContext();
}
- private IObservable<RequestContext> ObservableHttpContext()
+ private IObservable<HttpListenerContext> ObservableHttpContext()
{
- return Observable.Create<RequestContext>(obs =>
+ return Observable.Create<HttpListenerContext>(obs =>
Observable.FromAsyncPattern<HttpListenerContext>(listener.BeginGetContext,
listener.EndGetContext)()
- .Select(c => new RequestContext(c))
.Subscribe(obs))
.Repeat()
.Retry()
@@ -34,7 +33,7 @@ namespace MediaBrowser.Common.Net
listener.Stop();
}
- public IDisposable Subscribe(IObserver<RequestContext> observer)
+ public IDisposable Subscribe(IObserver<HttpListenerContext> observer)
{
return stream.Subscribe(observer);
}