File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed
Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -65,7 +65,9 @@ export class AsyncQueue<T> {
6565 close ( ) {
6666 this . closed = true ;
6767 // Reject all waiting producers with an error
68- this . waitingProducers . toArray ( ) . forEach ( ( producer ) => producer . reject ( new Error ( 'Queue closed' ) ) ) ;
68+ this . waitingProducers
69+ . toArray ( )
70+ . forEach ( ( producer ) => producer . reject ( new Error ( 'Queue closed' ) ) ) ;
6971 // Resolve all waiting consumers so they can see the queue is closed
7072 this . waitingConsumers . toArray ( ) . forEach ( ( resolve ) => resolve ( ) ) ;
7173 this . waitingProducers . clear ( ) ;
Original file line number Diff line number Diff line change 11// SPDX-FileCopyrightText: 2025 LiveKit, Inc.
22//
33// SPDX-License-Identifier: Apache-2.0
4- import { AudioFrame } from './audio_frame.js' ;
54import { AsyncQueue } from './async_queue.js' ;
5+ import { AudioFrame } from './audio_frame.js' ;
66
77// Re-export AsyncQueue for backward compatibility
88export { AsyncQueue } from './async_queue.js' ;
You can’t perform that action at this time.
0 commit comments