1a4d6ab4577710f648bf60f544f8dc231a8f307f44e782dc1692fb83b98bc228b503e6cfb51959326d78e08edc00abf91fc95e53d01150dfeb45f41c41f647 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. declare module "stream/promises" {
  2. import {
  3. FinishedOptions as _FinishedOptions,
  4. PipelineDestination,
  5. PipelineOptions,
  6. PipelinePromise,
  7. PipelineSource,
  8. PipelineTransform,
  9. } from "node:stream";
  10. interface FinishedOptions extends _FinishedOptions {
  11. /**
  12. * If true, removes the listeners registered by this function before the promise is fulfilled.
  13. * @default false
  14. */
  15. cleanup?: boolean | undefined;
  16. }
  17. function finished(
  18. stream: NodeJS.ReadableStream | NodeJS.WritableStream | NodeJS.ReadWriteStream,
  19. options?: FinishedOptions,
  20. ): Promise<void>;
  21. function pipeline<A extends PipelineSource<any>, B extends PipelineDestination<A, any>>(
  22. source: A,
  23. destination: B,
  24. options?: PipelineOptions,
  25. ): PipelinePromise<B>;
  26. function pipeline<
  27. A extends PipelineSource<any>,
  28. T1 extends PipelineTransform<A, any>,
  29. B extends PipelineDestination<T1, any>,
  30. >(
  31. source: A,
  32. transform1: T1,
  33. destination: B,
  34. options?: PipelineOptions,
  35. ): PipelinePromise<B>;
  36. function pipeline<
  37. A extends PipelineSource<any>,
  38. T1 extends PipelineTransform<A, any>,
  39. T2 extends PipelineTransform<T1, any>,
  40. B extends PipelineDestination<T2, any>,
  41. >(
  42. source: A,
  43. transform1: T1,
  44. transform2: T2,
  45. destination: B,
  46. options?: PipelineOptions,
  47. ): PipelinePromise<B>;
  48. function pipeline<
  49. A extends PipelineSource<any>,
  50. T1 extends PipelineTransform<A, any>,
  51. T2 extends PipelineTransform<T1, any>,
  52. T3 extends PipelineTransform<T2, any>,
  53. B extends PipelineDestination<T3, any>,
  54. >(
  55. source: A,
  56. transform1: T1,
  57. transform2: T2,
  58. transform3: T3,
  59. destination: B,
  60. options?: PipelineOptions,
  61. ): PipelinePromise<B>;
  62. function pipeline<
  63. A extends PipelineSource<any>,
  64. T1 extends PipelineTransform<A, any>,
  65. T2 extends PipelineTransform<T1, any>,
  66. T3 extends PipelineTransform<T2, any>,
  67. T4 extends PipelineTransform<T3, any>,
  68. B extends PipelineDestination<T4, any>,
  69. >(
  70. source: A,
  71. transform1: T1,
  72. transform2: T2,
  73. transform3: T3,
  74. transform4: T4,
  75. destination: B,
  76. options?: PipelineOptions,
  77. ): PipelinePromise<B>;
  78. function pipeline(
  79. streams: ReadonlyArray<NodeJS.ReadableStream | NodeJS.WritableStream | NodeJS.ReadWriteStream>,
  80. options?: PipelineOptions,
  81. ): Promise<void>;
  82. function pipeline(
  83. stream1: NodeJS.ReadableStream,
  84. stream2: NodeJS.ReadWriteStream | NodeJS.WritableStream,
  85. ...streams: Array<NodeJS.ReadWriteStream | NodeJS.WritableStream | PipelineOptions>
  86. ): Promise<void>;
  87. }
  88. declare module "node:stream/promises" {
  89. export * from "stream/promises";
  90. }