Fixing type problem on AsyncIter

This commit is contained in:
Fabian Stamm
2020-10-19 21:31:11 +02:00
parent 84ea29a210
commit d0e8a97e4c
3 changed files with 3 additions and 3 deletions

View File

@ -39,7 +39,7 @@ export default class AsyncIteratorFromCB<T> implements AsyncIterable<T> {
this.#onClose.forEach((cb) => cb());
}
[Symbol.asyncIterator]() {
[Symbol.asyncIterator](): AsyncIterator<T, undefined, any> {
const queue: IAsyncIteratorMessage<T>[] = [];
const signal = new Signal();
this.#onData.subscribe((data) => {