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");
89 return buffer.CopyToAsync (stream);
91 return SerializeToStreamAsync (stream, context);
94 protected async virtual Task<Stream> CreateContentReadStreamAsync ()
96 await LoadIntoBufferAsync ().ConfigureAwait (false);
100 static FixedMemoryStream CreateFixedMemoryStream (long maxBufferSize)
102 return new FixedMemoryStream (maxBufferSize);
105 public void Dispose ()
110 protected virtual void Dispose (bool disposing)
112 if (disposing && !disposed) {
120 public Task LoadIntoBufferAsync ()
122 return LoadIntoBufferAsync (65536);
125 public async Task LoadIntoBufferAsync (long maxBufferSize)
128 throw new ObjectDisposedException (GetType ().ToString ());
133 buffer = CreateFixedMemoryStream (maxBufferSize);
134 await SerializeToStreamAsync (buffer, null).ConfigureAwait (false);
135 buffer.Seek (0, SeekOrigin.Begin);
138 public async Task<Stream> ReadAsStreamAsync ()
141 throw new ObjectDisposedException (GetType ().ToString ());
144 return new MemoryStream (buffer.GetBuffer (), 0, (int)buffer.Length, false);
147 stream = await CreateContentReadStreamAsync ().ConfigureAwait (false);
152 public async Task<byte[]> ReadAsByteArrayAsync ()
154 await LoadIntoBufferAsync ().ConfigureAwait (false);
155 return buffer.ToArray ();
158 public async Task<string> ReadAsStringAsync ()
160 await LoadIntoBufferAsync ().ConfigureAwait (false);
161 if (buffer.Length == 0)
165 if (headers != null && headers.ContentType != null && headers.ContentType.CharSet != null) {
166 encoding = Encoding.GetEncoding (headers.ContentType.CharSet);
168 encoding = Encoding.UTF8;
171 return encoding.GetString (buffer.GetBuffer (), 0, (int) buffer.Length);
174 protected internal abstract Task SerializeToStreamAsync (Stream stream, TransportContext context);
175 protected internal abstract bool TryComputeLength (out long length);