( streamManager: StreamManager, name: string )
| 102 | ) => Promise<void>; |
| 103 | |
| 104 | function getPrivateMethodForTests<T extends (...args: never[]) => unknown>( |
| 105 | streamManager: StreamManager, |
| 106 | name: string |
| 107 | ): T { |
| 108 | const method: unknown = Reflect.get(streamManager, name); |
| 109 | expect(typeof method).toBe("function"); |
| 110 | if (typeof method !== "function") { |
| 111 | throw new Error(`Expected StreamManager.${name} to exist`); |
| 112 | } |
| 113 | return method as T; |
| 114 | } |
| 115 | |
| 116 | function getProcessStreamWithCleanupForTests( |
| 117 | streamManager: StreamManager |
no test coverage detected