FsaNodeReadStream.d.ts 1.0 KB

1234567891011121314151617181920212223
  1. import { Readable } from 'stream';
  2. import { Defer } from '../thingies/Defer';
  3. import type { FsaNodeFsOpenFile } from './FsaNodeFsOpenFile';
  4. import type { IReadStream } from '../node/types/misc';
  5. import type { IReadStreamOptions } from '../node/types/options';
  6. import type { FsaNodeFs } from './FsaNodeFs';
  7. export declare class FsaNodeReadStream extends Readable implements IReadStream {
  8. protected readonly fs: FsaNodeFs;
  9. protected readonly handle: Promise<FsaNodeFsOpenFile>;
  10. readonly path: string;
  11. protected readonly options: IReadStreamOptions;
  12. protected __pending__: boolean;
  13. protected __closed__: boolean;
  14. protected __bytes__: number;
  15. protected readonly __mutex__: <T = unknown>(code: import("../thingies/types").Code<T>) => Promise<T>;
  16. protected readonly __file__: Defer<FsaNodeFsOpenFile>;
  17. constructor(fs: FsaNodeFs, handle: Promise<FsaNodeFsOpenFile>, path: string, options: IReadStreamOptions);
  18. private __read__;
  19. private __close__;
  20. get bytesRead(): number;
  21. get pending(): boolean;
  22. _read(): void;
  23. }