diff options
| author | softworkz <softworkz@hotmail.com> | 2016-08-05 06:08:11 +0200 |
|---|---|---|
| committer | softworkz <softworkz@hotmail.com> | 2016-08-07 02:00:36 +0200 |
| commit | 433254c498d2e43acfd34e5c4fcee2fdcc2e767b (patch) | |
| tree | e04ddf9e4202800f5f4658d0bfe9e2f01675bfeb /MediaBrowser.Server.Implementations/HttpServer/AsyncStreamWriterFunc.cs | |
| parent | 894d87fabb812152c76443afcf1739fda7c578ff (diff) | |
Async stream handling: Use interface instead of Func<Stream,Task>
No functional changes
Diffstat (limited to 'MediaBrowser.Server.Implementations/HttpServer/AsyncStreamWriterFunc.cs')
| -rw-r--r-- | MediaBrowser.Server.Implementations/HttpServer/AsyncStreamWriterFunc.cs | 56 |
1 files changed, 0 insertions, 56 deletions
diff --git a/MediaBrowser.Server.Implementations/HttpServer/AsyncStreamWriterFunc.cs b/MediaBrowser.Server.Implementations/HttpServer/AsyncStreamWriterFunc.cs deleted file mode 100644 index 5aa01c706..000000000 --- a/MediaBrowser.Server.Implementations/HttpServer/AsyncStreamWriterFunc.cs +++ /dev/null @@ -1,56 +0,0 @@ -using System; -using System.Collections.Generic; -using System.IO; -using System.Threading.Tasks; -using ServiceStack; -using ServiceStack.Web; - -namespace MediaBrowser.Server.Implementations.HttpServer -{ - public class AsyncStreamWriterFunc : IStreamWriter, IAsyncStreamWriter, IHasOptions - { - /// <summary> - /// Gets or sets the source stream. - /// </summary> - /// <value>The source stream.</value> - private Func<Stream, Task> Writer { get; set; } - - /// <summary> - /// Gets the options. - /// </summary> - /// <value>The options.</value> - public IDictionary<string, string> Options { get; private set; } - - public Action OnComplete { get; set; } - public Action OnError { get; set; } - - /// <summary> - /// Initializes a new instance of the <see cref="StreamWriter" /> class. - /// </summary> - public AsyncStreamWriterFunc(Func<Stream, Task> writer, IDictionary<string, string> headers) - { - Writer = writer; - - if (headers == null) - { - headers = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase); - } - Options = headers; - } - - /// <summary> - /// Writes to. - /// </summary> - /// <param name="responseStream">The response stream.</param> - public void WriteTo(Stream responseStream) - { - var task = Writer(responseStream); - Task.WaitAll(task); - } - - public async Task WriteToAsync(Stream responseStream) - { - await Writer(responseStream).ConfigureAwait(false); - } - } -} |
