try {
request = SetupRequest (address);
- WebResponse response = request.GetResponse ();
- Stream st = ProcessResponse (response);
+ WebResponse response = GetWebResponse (request);
+ Stream st = response.GetResponseStream ();
return ReadAll (st, (int) response.ContentLength, userToken);
} catch (ThreadInterruptedException){
if (request != null)
using (FileStream f = new FileStream (fileName, FileMode.Create)) {
try {
request = SetupRequest (address);
- WebResponse response = request.GetResponse ();
- Stream st = ProcessResponse (response);
+ WebResponse response = GetWebResponse (request);
+ Stream st = response.GetResponseStream ();
int cLength = (int) response.ContentLength;
int length = (cLength <= -1 || cLength > 32*1024) ? 32*1024 : cLength;
async = false;
#endif
request = SetupRequest (address);
- WebResponse response = request.GetResponse ();
- return ProcessResponse (response);
+ WebResponse response = GetWebResponse (request);
+ return response.GetResponseStream ();
} catch (Exception ex) {
throw new WebException ("An error occurred " +
"performing a WebClient request.", ex);
stream.Write (data, 0, contentLength);
}
- WebResponse response = request.GetResponse ();
- Stream st = ProcessResponse (response);
+ WebResponse response = GetWebResponse (request);
+ Stream st = response.GetResponseStream ();
return ReadAll (st, (int) response.ContentLength, userToken);
} catch (ThreadInterruptedException){
if (request != null)
reqStream.Write (realBoundary, 0, realBoundary.Length);
reqStream.Close ();
reqStream = null;
- WebResponse response = request.GetResponse ();
- Stream st = ProcessResponse (response);
+ WebResponse response = GetWebResponse (request);
+ Stream st = response.GetResponseStream ();
resultBytes = ReadAll (st, (int) response.ContentLength, userToken);
} catch (ThreadInterruptedException){
if (request != null)
}
tmpStream.Close ();
- WebResponse response = request.GetResponse ();
- Stream st = ProcessResponse (response);
+ WebResponse response = GetWebResponse (request);
+ Stream st = response.GetResponseStream ();
return ReadAll (st, (int) response.ContentLength, userToken);
} catch (ThreadInterruptedException) {
request.Abort ();
return request;
}
- Stream ProcessResponse (WebResponse response)
- {
- responseHeaders = response.Headers;
- return response.GetResponseStream ();
- }
-
byte [] ReadAll (Stream stream, int length, object userToken)
{
MemoryStream ms = null;
WebRequest request = null;
try {
request = SetupRequest ((Uri) args [0]);
- WebResponse response = request.GetResponse ();
- Stream stream = ProcessResponse (response);
+ WebResponse response = GetWebResponse (request);
+ Stream stream = response.GetResponseStream ();
OnOpenReadCompleted (
new OpenReadCompletedEventArgs (stream, null, false, args [1]));
} catch (ThreadInterruptedException){
UploadValuesCompleted (this, args);
}
- [MonoNotSupported("")]
- protected virtual WebRequest GetWebRequest (Uri address)
+ protected virtual WebResponse GetWebResponse (WebRequest request, IAsyncResult result)
{
- throw new NotImplementedException ();
+ WebResponse response = request.EndGetResponse (result);
+ responseHeaders = response.Headers;
+ return response;
}
+#endif
- protected virtual WebResponse GetWebResponse (WebRequest request)
+#if NET_2_0
+ protected virtual
+#endif
+ WebRequest GetWebRequest (Uri address)
{
- return request.GetResponse ();
+ return SetupRequest (address);
}
- protected virtual WebResponse GetWebResponse (WebRequest request, IAsyncResult result)
+#if NET_2_0
+ protected virtual
+#endif
+ WebResponse GetWebResponse (WebRequest request)
{
- return request.EndGetResponse (result);
+ WebResponse response = request.GetResponse ();
+ responseHeaders = response.Headers;
+ return response;
}
-#endif
+
}
}
+