class Queueimport { Queue } from "https://deno.land/x/ayonli_jsext@v0.9.72/queue.ts"; ConstructorsnewQueue(handler: (data: T) => Promise<void>, bufferSize?)Type ParametersTPropertiesprivateoptionalchannel: Channel<T>privateoptionalerrorHandler: (err: unknown) => voidMethodsclose()onError(handler: (err: unknown) => void)push(data: T): Promise<void>[Symbol.dispose]()