Method pull

cbor/_array_decoded_stream.ts:48–54

(controller)

  constructor(gen: AsyncGenerator<CborStreamOutput>, releaseLock: ReleaseLock) {
    super({
      async pull(controller) {
        const { done, value } = await gen.next();
        if (done) {
          releaseLock();
          controller.close();
        } else controller.enqueue(value);
      },
      async cancel() {
        // deno-lint-ignore no-empty
        for await (const _ of gen) {}