diff options
| author | LukePulverenti Luke Pulverenti luke pulverenti <LukePulverenti Luke Pulverenti luke.pulverenti@gmail.com> | 2012-08-10 09:07:58 -0400 |
|---|---|---|
| committer | LukePulverenti Luke Pulverenti luke pulverenti <LukePulverenti Luke Pulverenti luke.pulverenti@gmail.com> | 2012-08-10 09:07:58 -0400 |
| commit | 2536011247de55c75e8b1f893e23b606e4200159 (patch) | |
| tree | f0cfa3893da3eedea162b651355088d068ade0ef /MediaBrowser.Common/Net/HttpServer.cs | |
| parent | dce7706382aaacae5ee74ba5048b76269e5390e5 (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.cs | 11 |
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);
}
|
