mirror of
https://github.com/denoland/deno.git
synced 2024-12-25 08:39:09 -05:00
f184332c09
* Prepend underscores to private modules * Remove collectUint8Arrays() It would be a misuse of Deno.iter()'s result. * Move std/_util/async.ts to std/async * Move std/util/sha*.ts to std/hash
28 lines
752 B
TypeScript
28 lines
752 B
TypeScript
// Copyright 2018-2020 the Deno authors. All rights reserved. MIT license.
|
|
import { assertEquals } from "../testing/asserts.ts";
|
|
import { MuxAsyncIterator } from "./mux_async_iterator.ts";
|
|
|
|
// eslint-disable-next-line require-await
|
|
async function* gen123(): AsyncIterableIterator<number> {
|
|
yield 1;
|
|
yield 2;
|
|
yield 3;
|
|
}
|
|
|
|
// eslint-disable-next-line require-await
|
|
async function* gen456(): AsyncIterableIterator<number> {
|
|
yield 4;
|
|
yield 5;
|
|
yield 6;
|
|
}
|
|
|
|
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);
|
|
});
|