Skip to content

Commit

Permalink
BREAKING(streams): remove iterateReader, readableStreamFromReader
Browse files Browse the repository at this point in the history
…, `readerFromIterable`, `readerFromStreamReader`, `writableStreamFromWriter`, and `writerFromStreamWriter` (#5060)
  • Loading branch information
kt3k committed Jun 17, 2024
1 parent cea0a14 commit 4837997
Show file tree
Hide file tree
Showing 15 changed files with 4 additions and 823 deletions.
6 changes: 4 additions & 2 deletions io/iterate_reader_test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ import { assertEquals } from "@std/assert/assert-equals";
// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.

import { iterateReader, iterateReaderSync } from "./iterate_reader.ts";
import { readerFromIterable } from "@std/streams/reader-from-iterable";
import { readerFromStreamReader } from "./reader_from_stream_reader.ts";
import { delay } from "@std/async/delay";
import type { Reader, ReaderSync } from "./types.ts";

Expand Down Expand Up @@ -45,7 +45,9 @@ Deno.test("iterateReader()", async () => {
Deno.test("iterateReader() works with slow consumer", async () => {
const a = new Uint8Array([97]);
const b = new Uint8Array([98]);
const iter = iterateReader(readerFromIterable([a, b]));
const iter = iterateReader(
readerFromStreamReader(ReadableStream.from([a, b]).getReader()),
);
const promises = [];
for await (const bytes of iter) {
promises.push(delay(10).then(() => bytes));
Expand Down
6 changes: 0 additions & 6 deletions streams/deno.json
Original file line number Diff line number Diff line change
Expand Up @@ -8,22 +8,16 @@
"./concat-readable-streams": "./concat_readable_streams.ts",
"./delimiter-stream": "./delimiter_stream.ts",
"./early-zip-readable-streams": "./early_zip_readable_streams.ts",
"./iterate-reader": "./iterate_reader.ts",
"./limited-bytes-transform-stream": "./limited_bytes_transform_stream.ts",
"./limited-transform-stream": "./limited_transform_stream.ts",
"./merge-readable-streams": "./merge_readable_streams.ts",
"./readable-stream-from-reader": "./readable_stream_from_reader.ts",
"./reader-from-iterable": "./reader_from_iterable.ts",
"./reader-from-stream-reader": "./reader_from_stream_reader.ts",
"./text-delimiter-stream": "./text_delimiter_stream.ts",
"./text-line-stream": "./text_line_stream.ts",
"./to-array-buffer": "./to_array_buffer.ts",
"./to-blob": "./to_blob.ts",
"./to-json": "./to_json.ts",
"./to-text": "./to_text.ts",
"./to-transform-stream": "./to_transform_stream.ts",
"./writable-stream-from-writer": "./writable_stream_from_writer.ts",
"./writer-from-stream-writer": "./writer_from_stream_writer.ts",
"./zip-readable-streams": "./zip_readable_streams.ts"
}
}
99 changes: 0 additions & 99 deletions streams/iterate_reader.ts

This file was deleted.

111 changes: 0 additions & 111 deletions streams/iterate_reader_test.ts

This file was deleted.

6 changes: 0 additions & 6 deletions streams/mod.ts
Original file line number Diff line number Diff line change
Expand Up @@ -23,20 +23,14 @@ export * from "./byte_slice_stream.ts";
export * from "./concat_readable_streams.ts";
export * from "./delimiter_stream.ts";
export * from "./early_zip_readable_streams.ts";
export * from "./iterate_reader.ts";
export * from "./limited_bytes_transform_stream.ts";
export * from "./limited_transform_stream.ts";
export * from "./merge_readable_streams.ts";
export * from "./readable_stream_from_reader.ts";
export * from "./reader_from_iterable.ts";
export * from "./reader_from_stream_reader.ts";
export * from "./text_delimiter_stream.ts";
export * from "./text_line_stream.ts";
export * from "./to_array_buffer.ts";
export * from "./to_blob.ts";
export * from "./to_json.ts";
export * from "./to_text.ts";
export * from "./to_transform_stream.ts";
export * from "./writable_stream_from_writer.ts";
export * from "./writer_from_stream_writer.ts";
export * from "./zip_readable_streams.ts";
56 changes: 0 additions & 56 deletions streams/readable_stream_from_reader.ts

This file was deleted.

Loading

0 comments on commit 4837997

Please sign in to comment.