Class NativeReaderWriter

components/runtime/src/ts/unstable/streams.ts:17–35

 * @internal
 */
export class NativeReaderWriter implements AsyncReader, AsyncWriter, AsyncReadCloser {
    rid: number;

    constructor(rid: number) {
        this.rid = rid
    }

    read(buf: Uint8Array): Promise<number> {
        return Deno.core.read(this.rid, buf);
    }

    write(data: Uint8Array): Promise<number> {
        return Deno.core.write(this.rid, data)
    }

    close(): void {
        Deno.core.close(this.rid);
    }
}

/**
 * @internal