summaryrefslogtreecommitdiff
path: root/std/async/mux_async_iterator_test.ts
diff options
context:
space:
mode:
Diffstat (limited to 'std/async/mux_async_iterator_test.ts')
-rw-r--r--std/async/mux_async_iterator_test.ts50
1 files changed, 0 insertions, 50 deletions
diff --git a/std/async/mux_async_iterator_test.ts b/std/async/mux_async_iterator_test.ts
deleted file mode 100644
index e1bdb47b4..000000000
--- a/std/async/mux_async_iterator_test.ts
+++ /dev/null
@@ -1,50 +0,0 @@
-// Copyright 2018-2021 the Deno authors. All rights reserved. MIT license.
-import { assertEquals, assertThrowsAsync } from "../testing/asserts.ts";
-import { MuxAsyncIterator } from "./mux_async_iterator.ts";
-
-async function* gen123(): AsyncIterableIterator<number> {
- yield 1;
- yield 2;
- yield 3;
-}
-
-async function* gen456(): AsyncIterableIterator<number> {
- yield 4;
- yield 5;
- yield 6;
-}
-
-async function* genThrows(): AsyncIterableIterator<number> {
- yield 7;
- throw new Error("something went wrong");
-}
-
-Deno.test("[async] MuxAsyncIterator", async function (): Promise<void> {
- const mux = new MuxAsyncIterator<number>();
- mux.add(gen123());
- mux.add(gen456());
- const results = new Set();
- for await (const value of mux) {
- results.add(value);
- }
- assertEquals(results.size, 6);
-});
-
-Deno.test({
- name: "[async] MuxAsyncIterator throws",
- async fn() {
- const mux = new MuxAsyncIterator<number>();
- mux.add(gen123());
- mux.add(genThrows());
- const results = new Set();
- await assertThrowsAsync(
- async () => {
- for await (const value of mux) {
- results.add(value);
- }
- },
- Error,
- "something went wrong",
- );
- },
-});