Class UHidOutputStream

libraries/scrcpy/src/2_4/impl/uhid-output-stream.ts:20–48

>;

export class UHidOutputStream
    extends PushReadableStream<UHidOutputDeviceMessage>
    implements ScrcpyDeviceMessageParser
{
    #controller: PushReadableStreamController<UHidOutputDeviceMessage>;

    readonly id = 2;

    constructor() {
        let controller!: PushReadableStreamController<UHidOutputDeviceMessage>;
        super((controller_) => {
            controller = controller_;
        });
        this.#controller = controller;
    }

    async parse(_id: number, stream: AsyncExactReadable): Promise<undefined> {
        const message = await UHidOutputDeviceMessage.deserialize(stream);
        await this.#controller.enqueue(message);
    }

    close() {
        this.#controller.close();
    }

    error(e?: unknown) {
        this.#controller.error(e);
    }
}