5 // Marek Safar <marek.safar@gmail.com>
7 // Copyright (C) 2011 Xamarin Inc (http://www.xamarin.com)
9 // Permission is hereby granted, free of charge, to any person obtaining
10 // a copy of this software and associated documentation files (the
11 // "Software"), to deal in the Software without restriction, including
12 // without limitation the rights to use, copy, modify, merge, publish,
13 // distribute, sublicense, and/or sell copies of the Software, and to
14 // permit persons to whom the Software is furnished to do so, subject to
15 // the following conditions:
17 // The above copyright notice and this permission notice shall be
18 // included in all copies or substantial portions of the Software.
20 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
21 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
22 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
23 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
24 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
25 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
26 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
29 using System.Net.Http.Headers;
31 using System.Threading.Tasks;
34 namespace System.Net.Http
36 public abstract class HttpContent : IDisposable
38 sealed class FixedMemoryStream : MemoryStream
40 readonly long maxSize;
42 public FixedMemoryStream (long maxSize)
45 this.maxSize = maxSize;
48 void CheckOverflow (int count)
50 if (Length + count > maxSize)
51 throw new HttpRequestException (string.Format ("Cannot write more bytes to the buffer than the configured maximum buffer size: {0}", maxSize));
54 public override void WriteByte (byte value)
57 base.WriteByte (value);
60 public override void Write (byte[] buffer, int offset, int count)
62 CheckOverflow (count);
63 base.Write (buffer, offset, count);
67 FixedMemoryStream buffer;
70 HttpContentHeaders headers;
72 public HttpContentHeaders Headers {
74 return headers ?? (headers = new HttpContentHeaders (this));
78 public Task CopyToAsync (Stream stream)
80 return CopyToAsync (stream, null);
83 public Task CopyToAsync (Stream stream, TransportContext context)
86 throw new ArgumentNullException ("stream");
88 return SerializeToStreamAsync (stream, context);
91 protected async virtual Task<Stream> CreateContentReadStreamAsync ()
93 await LoadIntoBufferAsync ().ConfigureAwait (false);
97 static FixedMemoryStream CreateFixedMemoryStream (long maxBufferSize)
99 return new FixedMemoryStream (maxBufferSize);
102 public void Dispose ()
107 protected virtual void Dispose (bool disposing)
109 if (disposing && !disposed) {
117 public Task LoadIntoBufferAsync ()
119 return LoadIntoBufferAsync (65536);
122 public async Task LoadIntoBufferAsync (long maxBufferSize)
125 throw new ObjectDisposedException (GetType ().ToString ());
130 buffer = CreateFixedMemoryStream (maxBufferSize);
131 await SerializeToStreamAsync (buffer, null).ConfigureAwait (false);
132 buffer.Seek (0, SeekOrigin.Begin);
135 public async Task<Stream> ReadAsStreamAsync ()
138 throw new ObjectDisposedException (GetType ().ToString ());
141 stream = await CreateContentReadStreamAsync ().ConfigureAwait (false);
146 public async Task<byte[]> ReadAsByteArrayAsync ()
148 await LoadIntoBufferAsync ().ConfigureAwait (false);
149 return buffer.ToArray ();
152 public async Task<string> ReadAsStringAsync ()
154 await LoadIntoBufferAsync ().ConfigureAwait (false);
155 if (buffer.Length == 0)
159 if (headers != null && headers.ContentType != null && headers.ContentType.CharSet != null) {
160 encoding = Encoding.GetEncoding (headers.ContentType.CharSet);
162 encoding = Encoding.UTF8;
165 return encoding.GetString (buffer.GetBuffer (), 0, (int) buffer.Length);
168 protected internal abstract Task SerializeToStreamAsync (Stream stream, TransportContext context);
169 protected internal abstract bool TryComputeLength (out long length);