Class ClipboardStream

libraries/scrcpy/src/1_15/impl/clipboard-stream.ts:13–41

);

export class ClipboardStream
    extends PushReadableStream<string>
    implements ScrcpyDeviceMessageParser
{
    #controller: PushReadableStreamController<string>;

    readonly id = 0;

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

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

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

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