Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(956)

Unified Diff: pkg/http/lib/src/utils.dart

Issue 810223002: Remove the http package from the repo. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 6 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: pkg/http/lib/src/utils.dart
diff --git a/pkg/http/lib/src/utils.dart b/pkg/http/lib/src/utils.dart
deleted file mode 100644
index dde507a5e57c1ca31cf4653a9cc5e780e0feb170..0000000000000000000000000000000000000000
--- a/pkg/http/lib/src/utils.dart
+++ /dev/null
@@ -1,201 +0,0 @@
-// Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file
-// for details. All rights reserved. Use of this source code is governed by a
-// BSD-style license that can be found in the LICENSE file.
-
-library utils;
-
-import 'dart:async';
-import 'dart:convert';
-import 'dart:typed_data';
-
-import 'package:stack_trace/stack_trace.dart';
-
-import 'byte_stream.dart';
-
-/// Converts a URL query string (or `application/x-www-form-urlencoded` body)
-/// into a [Map] from parameter names to values.
-///
-/// queryToMap("foo=bar&baz=bang&qux");
-/// //=> {"foo": "bar", "baz": "bang", "qux": ""}
-Map<String, String> queryToMap(String queryList, {Encoding encoding}) {
- var map = {};
- for (var pair in queryList.split("&")) {
- var split = split1(pair, "=");
- if (split.isEmpty) continue;
- var key = Uri.decodeQueryComponent(split[0], encoding: encoding);
- var value = Uri.decodeQueryComponent(split.length > 1 ? split[1] : "",
- encoding: encoding);
- map[key] = value;
- }
- return map;
-}
-
-/// Converts a [Map] from parameter names to values to a URL query string.
-///
-/// mapToQuery({"foo": "bar", "baz": "bang"});
-/// //=> "foo=bar&baz=bang"
-String mapToQuery(Map<String, String> map, {Encoding encoding}) {
- var pairs = <List<String>>[];
- map.forEach((key, value) =>
- pairs.add([Uri.encodeQueryComponent(key, encoding: encoding),
- Uri.encodeQueryComponent(value, encoding: encoding)]));
- return pairs.map((pair) => "${pair[0]}=${pair[1]}").join("&");
-}
-
-/// Like [String.split], but only splits on the first occurrence of the pattern.
-/// This will always return an array of two elements or fewer.
-///
-/// split1("foo,bar,baz", ","); //=> ["foo", "bar,baz"]
-/// split1("foo", ","); //=> ["foo"]
-/// split1("", ","); //=> []
-List<String> split1(String toSplit, String pattern) {
- if (toSplit.isEmpty) return <String>[];
-
- var index = toSplit.indexOf(pattern);
- if (index == -1) return [toSplit];
- return [
- toSplit.substring(0, index),
- toSplit.substring(index + pattern.length)
- ];
-}
-
-/// Returns the [Encoding] that corresponds to [charset]. Returns [fallback] if
-/// [charset] is null or if no [Encoding] was found that corresponds to
-/// [charset].
-Encoding encodingForCharset(String charset, [Encoding fallback = LATIN1]) {
- if (charset == null) return fallback;
- var encoding = Encoding.getByName(charset);
- return encoding == null ? fallback : encoding;
-}
-
-
-/// Returns the [Encoding] that corresponds to [charset]. Throws a
-/// [FormatException] if no [Encoding] was found that corresponds to [charset].
-/// [charset] may not be null.
-Encoding requiredEncodingForCharset(String charset) {
- var encoding = Encoding.getByName(charset);
- if (encoding != null) return encoding;
- throw new FormatException('Unsupported encoding "$charset".');
-}
-
-/// A regular expression that matches strings that are composed entirely of
-/// ASCII-compatible characters.
-final RegExp _ASCII_ONLY = new RegExp(r"^[\x00-\x7F]+$");
-
-/// Returns whether [string] is composed entirely of ASCII-compatible
-/// characters.
-bool isPlainAscii(String string) => _ASCII_ONLY.hasMatch(string);
-
-/// Converts [input] into a [Uint8List].
-///
-/// If [input] is a [TypedData], this just returns a view on [input].
-Uint8List toUint8List(List<int> input) {
- if (input is Uint8List) return input;
- if (input is TypedData) {
- // TODO(nweiz): remove "as" when issue 11080 is fixed.
- return new Uint8List.view((input as TypedData).buffer);
- }
- return new Uint8List.fromList(input);
-}
-
-/// If [stream] is already a [ByteStream], returns it. Otherwise, wraps it in a
-/// [ByteStream].
-ByteStream toByteStream(Stream<List<int>> stream) {
- if (stream is ByteStream) return stream;
- return new ByteStream(stream);
-}
-
-/// Calls [onDone] once [stream] (a single-subscription [Stream]) is finished.
-/// The return value, also a single-subscription [Stream] should be used in
-/// place of [stream] after calling this method.
-Stream onDone(Stream stream, void onDone()) {
- var pair = tee(stream);
- pair.first.listen((_) {}, onError: (_) {}, onDone: onDone);
- return pair.last;
-}
-
-// TODO(nweiz): remove this when issue 7786 is fixed.
-/// Pipes all data and errors from [stream] into [sink]. When [stream] is done,
-/// [sink] is closed and the returned [Future] is completed.
-Future store(Stream stream, EventSink sink) {
- var completer = new Completer();
- stream.listen(sink.add,
- onError: sink.addError,
- onDone: () {
- sink.close();
- completer.complete();
- });
- return completer.future;
-}
-
-/// Pipes all data and errors from [stream] into [sink]. Completes [Future] once
-/// [stream] is done. Unlike [store], [sink] remains open after [stream] is
-/// done.
-Future writeStreamToSink(Stream stream, EventSink sink) {
- var completer = new Completer();
- stream.listen(sink.add,
- onError: sink.addError,
- onDone: () => completer.complete());
- return completer.future;
-}
-
-/// Returns a [Future] that asynchronously completes to `null`.
-Future get async => new Future.value();
-
-/// Returns a closed [Stream] with no elements.
-Stream get emptyStream => streamFromIterable([]);
-
-/// Creates a single-subscription stream that emits the items in [iter] and then
-/// ends.
-Stream streamFromIterable(Iterable iter) {
- var controller = new StreamController(sync: true);
- iter.forEach(controller.add);
- controller.close();
- return controller.stream;
-}
-
-// TODO(nweiz): remove this when issue 7787 is fixed.
-/// Creates two single-subscription [Stream]s that each emit all values and
-/// errors from [stream]. This is useful if [stream] is single-subscription but
-/// multiple subscribers are necessary.
-Pair<Stream, Stream> tee(Stream stream) {
- var controller1 = new StreamController(sync: true);
- var controller2 = new StreamController(sync: true);
- stream.listen((value) {
- controller1.add(value);
- controller2.add(value);
- }, onError: (error, [StackTrace stackTrace]) {
- controller1.addError(error, stackTrace);
- controller2.addError(error, stackTrace);
- }, onDone: () {
- controller1.close();
- controller2.close();
- });
- return new Pair<Stream, Stream>(controller1.stream, controller2.stream);
-}
-
-/// A pair of values.
-class Pair<E, F> {
- E first;
- F last;
-
- Pair(this.first, this.last);
-
- String toString() => '($first, $last)';
-
- bool operator==(other) {
- if (other is! Pair) return false;
- return other.first == first && other.last == last;
- }
-
- int get hashCode => first.hashCode ^ last.hashCode;
-}
-
-/// Configures [future] so that its result (success or exception) is passed on
-/// to [completer].
-void chainToCompleter(Future future, Completer completer) {
- future.then(completer.complete, onError: completer.completeError);
-}
-
-/// Like [Future.sync], but wraps the Future in [Chain.track] as well.
-Future syncFuture(callback()) => Chain.track(new Future.sync(callback));
« no previous file with comments | « pkg/http/lib/src/streamed_response.dart ('k') | pkg/http/lib/testing.dart » ('j') | pkg/pkg.gyp » ('J')

Powered by Google App Engine
This is Rietveld 408576698