Index: runtime/bin/input_stream.dart |
diff --git a/runtime/bin/input_stream.dart b/runtime/bin/input_stream.dart |
deleted file mode 100644 |
index 755f54e68a2ad2ffa13ee79a896bfa4fb0cff436..0000000000000000000000000000000000000000 |
--- a/runtime/bin/input_stream.dart |
+++ /dev/null |
@@ -1,251 +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. |
- |
-/** |
- * Basic input stream which supplies binary data. |
- * |
- * Input streams are used to read data sequentially from some data |
- * source. All input streams are non-blocking. They each have a number |
- * of read calls which will always return without any IO related |
- * blocking. If the requested data is not available a read call will |
- * return `null`. All input streams have one or more handlers which |
- * will trigger when data is available. |
- * |
- * The following example shows a data handler in an ordinary input |
- * stream which will be called when some data is available and a call |
- * to read will not return `null`. |
- * |
- * InputStream input = ... |
- * input.onData = () { |
- * var data = input.read(); |
- * ... |
- * }; |
- * |
- * If for some reason the data from an input stream cannot be handled |
- * by the application immediately setting the data handler to `null` |
- * will avoid further callbacks until it is set to a function |
- * again. While the data handler is not active system flow control |
- * will be used to avoid buffering more data than needed. |
- * |
- * Always set up appropriate handlers when using input streams. |
- * |
- */ |
-abstract class InputStream { |
- /** |
- * Reads data from the stream. Returns a system allocated buffer |
- * with up to [len] bytes. If no value is passed for [len] all |
- * available data will be returned. If no data is available null will |
- * be returned. |
- */ |
- List<int> read([int len]); |
- |
- /** |
- * Reads up to [len] bytes into buffer [buffer] starting at offset |
- * [offset]. Returns the number of bytes actually read which might |
- * be zero. If [offset] is not specified 0 is used. If [len] is not |
- * specified the length of [buffer] is used. |
- */ |
- int readInto(List<int> buffer, [int offset, int len]); |
- |
- /** |
- * Returns the number of bytes available for immediate reading. |
- */ |
- int available(); |
- |
- /** |
- * Pipe the content of this input stream directly to the output |
- * stream [output]. The default behavior is to close the output when |
- * all the data from the input stream have been written. Specifying |
- * `false` for the optional argument [close] keeps the output |
- * stream open after writing all data from the input stream. |
- */ |
- void pipe(OutputStream output, [bool close = true]); |
- |
- /** |
- * Close the underlying communication channel to avoid getting any |
- * more data. In normal situations, where all data is read from the |
- * stream until the close handler is called, calling [close] is not |
- * required. When [close] is used the close handler will still be |
- * called. |
- */ |
- void close(); |
- |
- /** |
- * Returns whether the stream is closed. There will be no more data |
- * to read. |
- */ |
- bool get closed; |
- |
- /** |
- * Sets the handler that gets called when data is available. |
- */ |
- void set onData(void callback()); |
- |
- /** |
- * Sets the handler that gets called when there will be no more data |
- * available in the stream. |
- */ |
- void set onClosed(void callback()); |
- |
- /** |
- * Sets the handler that gets called when the underlying |
- * communication channel gets into some kind of error situation. |
- */ |
- void set onError(void callback(e)); |
-} |
- |
- |
-/** |
- * String encodings. |
- */ |
-class Encoding { |
- static const Encoding UTF_8 = const Encoding._internal("UTF-8"); |
- static const Encoding ISO_8859_1 = const Encoding._internal("ISO-8859-1"); |
- static const Encoding ASCII = const Encoding._internal("ASCII"); |
- const Encoding._internal(String this.name); |
- final String name; |
-} |
- |
- |
-/** |
- * A string input stream wraps a basic input stream and supplies |
- * string data. This data can be read either as string chunks or as |
- * lines separated by line termination character sequences. |
- */ |
-abstract class StringInputStream { |
- /** |
- * Decodes a binary input stream into characters using the specified |
- * encoding. |
- */ |
- factory StringInputStream(InputStream input, |
- [Encoding encoding = Encoding.UTF_8]) { |
- return new _StringInputStream(input, encoding); |
- } |
- |
- /** |
- * Reads up to [len] characters from the stream. if [len] is not |
- * specified reads as many characters as is available from the |
- * stream. If no data is available null will be returned. |
- */ |
- String read([int len]); |
- |
- /** |
- * Reads the next line from the stream. The line ending characters |
- * will not be part of the returned string. If a full line is not |
- * available null will be returned. |
- */ |
- String readLine(); |
- |
- /** |
- * Returns the number of characters available for immediate |
- * reading. Note that this includes all characters that will be in |
- * the String returned from [read] this includes line breaking |
- * characters. If [readLine] is used for reading one can observe |
- * less characters being returned as the line breaking characters |
- * are discarded. |
- */ |
- int available(); |
- |
- /** |
- * Returns whether the stream has been closed. There might still be |
- * more data to read. |
- */ |
- bool get closed; |
- |
- /** |
- * Returns the encoding used to decode the binary data into characters. |
- */ |
- Encoding get encoding; |
- |
- /** |
- * Sets the handler that gets called when data is available. The two |
- * handlers [onData] and [onLine] are mutually exclusive |
- * and setting one will remove the other. |
- */ |
- void set onData(void callback()); |
- |
- /** |
- * Sets the handler that gets called when a line is available. The |
- * two handlers [onData] and [onLine] are mutually |
- * exclusive and setting one will remove the other. |
- */ |
- void set onLine(void callback()); |
- |
- /** |
- * Sets the handler that gets called when there will be no more data |
- * available in the stream. |
- */ |
- void set onClosed(void callback()); |
- |
- /** |
- * Sets the handler that gets called when the underlying |
- * communication channel gets into some kind of error situation. |
- */ |
- void set onError(void callback(e)); |
-} |
- |
- |
-/** |
- * A chunked input stream wraps a basic input stream and supplies |
- * binary data in configurable chunk sizes. |
- */ |
-abstract class ChunkedInputStream { |
- /** |
- * Adds buffering to an input stream and provide the ability to read |
- * the data in known size chunks. |
- */ |
- factory ChunkedInputStream(InputStream input, [int chunkSize = 0]) { |
- return new _ChunkedInputStream(input, chunkSize); |
- } |
- |
- /** |
- * Reads [chunkSize] bytes from the stream. If [chunkSize] bytes are |
- * not currently available null is returned. When the stream is |
- * closed the last call can return with less than [chunkSize] bytes. |
- */ |
- List<int> read(); |
- |
- /** |
- * Returns whether the stream has been closed. There might still be |
- * more data to read. |
- */ |
- bool get closed; |
- |
- /** |
- * Returns the chunk size used by this stream. |
- */ |
- int get chunkSize; |
- |
- /** |
- * Sets the chunk size used by this stream. |
- */ |
- void set chunkSize(int chunkSize); |
- |
- /** |
- * Sets the handler that gets called when at least [chunkSize] bytes |
- * of data is available or the underlying stream has been closed and |
- * there is still unread data. |
- */ |
- void set onData(void callback()); |
- |
- /** |
- * Sets the handler that gets called when there will be no more data |
- * available in the stream. |
- */ |
- void set onClosed(void callback()); |
- |
- /** |
- * Sets the handler that gets called when the underlying |
- * communication channel gets into some kind of error situation. |
- */ |
- void set onError(void callback(e)); |
-} |
- |
- |
-class StreamException implements Exception { |
- const StreamException([String this.message = ""]); |
- const StreamException.streamClosed() : message = "Stream closed"; |
- String toString() => "StreamException: $message"; |
- final String message; |
-} |