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 internal long? LoadedBufferLength {
80 return buffer == null ? (long?)null : buffer.Length;
84 public Task CopyToAsync (Stream stream)
86 return CopyToAsync (stream, null);
89 public Task CopyToAsync (Stream stream, TransportContext context)
92 throw new ArgumentNullException ("stream");
95 return buffer.CopyToAsync (stream);
97 return SerializeToStreamAsync (stream, context);
100 protected async virtual Task<Stream> CreateContentReadStreamAsync ()
102 await LoadIntoBufferAsync ().ConfigureAwait (false);
106 static FixedMemoryStream CreateFixedMemoryStream (long maxBufferSize)
108 return new FixedMemoryStream (maxBufferSize);
111 public void Dispose ()
116 protected virtual void Dispose (bool disposing)
118 if (disposing && !disposed) {
126 public Task LoadIntoBufferAsync ()
128 return LoadIntoBufferAsync (int.MaxValue);
131 public async Task LoadIntoBufferAsync (long maxBufferSize)
134 throw new ObjectDisposedException (GetType ().ToString ());
139 buffer = CreateFixedMemoryStream (maxBufferSize);
140 await SerializeToStreamAsync (buffer, null).ConfigureAwait (false);
141 buffer.Seek (0, SeekOrigin.Begin);
144 public async Task<Stream> ReadAsStreamAsync ()
147 throw new ObjectDisposedException (GetType ().ToString ());
150 return new MemoryStream (buffer.GetBuffer (), 0, (int)buffer.Length, false);
153 stream = await CreateContentReadStreamAsync ().ConfigureAwait (false);
158 public async Task<byte[]> ReadAsByteArrayAsync ()
160 await LoadIntoBufferAsync ().ConfigureAwait (false);
161 return buffer.ToArray ();
164 public async Task<string> ReadAsStringAsync ()
166 await LoadIntoBufferAsync ().ConfigureAwait (false);
167 if (buffer.Length == 0)
171 if (headers != null && headers.ContentType != null && headers.ContentType.CharSet != null) {
172 encoding = Encoding.GetEncoding (headers.ContentType.CharSet);
174 encoding = Encoding.UTF8;
177 return encoding.GetString (buffer.GetBuffer (), 0, (int) buffer.Length);
180 protected internal abstract Task SerializeToStreamAsync (Stream stream, TransportContext context);
181 protected internal abstract bool TryComputeLength (out long length);