Skip to content

Commit

Permalink
Add some code comments
Browse files Browse the repository at this point in the history
  • Loading branch information
duwen committed Feb 21, 2019
1 parent 3f0042d commit d6452af
Show file tree
Hide file tree
Showing 3 changed files with 19 additions and 7 deletions.
11 changes: 8 additions & 3 deletions example/test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,15 @@ import 'dart:io';
import 'package:dio/dio.dart';

main() async {
var dio = new Dio(BaseOptions(connectTimeout: 50));
dio.interceptors.add(LogInterceptor(responseBody: true));
var dio = new Dio(
BaseOptions(
//connectTimeout: 5000,
baseUrl: "http://www.dtworkroom.com/doris/1/2.0.0/",
),
);
dio.interceptors.add(LogInterceptor());
await dio.get(
"http://www.dtworkroom.com/doris/1/2.0.0/test",
"/test",
queryParameters: {"kk": "tt"},
options: Options(
headers: {HttpHeaders.acceptEncodingHeader: "*"},
Expand Down
13 changes: 10 additions & 3 deletions package_src/lib/src/adapter.dart
Original file line number Diff line number Diff line change
Expand Up @@ -84,11 +84,17 @@ class DefaultHttpClientAdapter extends HttpClientAdapter {
) async {
_configHttpClient();
Future requestFuture;

if (options.connectTimeout > 0) {
// Because there is a bug in [httpClient.connectionTimeout] now, we replace it
// with `Future.timeout()` when it comes.
// Bug issue: https://github.com/dart-lang/sdk/issues/34980.
//_httpClient.connectionTimeout= Duration(milliseconds: options.connectTimeout);
requestFuture = _httpClient
.openUrl(options.method, options.uri)
.timeout(new Duration(milliseconds: options.connectTimeout));
.timeout(Duration(milliseconds: options.connectTimeout));
} else {
_httpClient.connectionTimeout = null;
requestFuture = _httpClient.openUrl(options.method, options.uri);
}

Expand All @@ -103,6 +109,8 @@ class DefaultHttpClientAdapter extends HttpClientAdapter {
message: "Connecting timeout[${options.connectTimeout}ms]",
type: DioErrorType.CONNECT_TIMEOUT,
);
} catch (e) {
print(e);
}
request.followRedirects = options.followRedirects;

Expand All @@ -119,10 +127,9 @@ class DefaultHttpClientAdapter extends HttpClientAdapter {
);
}


void _configHttpClient() {
if (_httpClient == null) _httpClient = new HttpClient();
_httpClient.idleTimeout = new Duration(seconds: 3);
_httpClient.idleTimeout = Duration(seconds: 3);
if (onHttpClientCreate != null) {
//user can return a new HttpClient instance
_httpClient = onHttpClientCreate(_httpClient) ?? _httpClient;
Expand Down
2 changes: 1 addition & 1 deletion package_src/lib/src/interceptors/cookie_mgr.dart
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ class CookieManager extends Interceptor {
var cookies = cookieJar.loadForRequest(options.uri)
..addAll(options.cookies);
String cookie = getCookies(cookies);
if (cookie.isNotEmpty) options.headers["cookie"] = cookie;
if (cookie.isNotEmpty) options.headers[HttpHeaders.cookieHeader] = cookie;
}

@override
Expand Down

0 comments on commit d6452af

Please sign in to comment.