1 | import { WritableStreamBuffer } from 'stream-buffers';
|
2 | import type { Options, Workers } from '@wdio/types';
|
3 | import WorkerInstance from './worker.js';
|
4 | export type { WorkerInstance };
|
5 | export interface RunArgs extends Workers.WorkerRunPayload {
|
6 | command: string;
|
7 | args: any;
|
8 | }
|
9 | export default class LocalRunner {
|
10 | private _options;
|
11 | protected _config: Options.Testrunner;
|
12 | workerPool: Record<string, WorkerInstance>;
|
13 | stdout: WritableStreamBuffer;
|
14 | stderr: WritableStreamBuffer;
|
15 | constructor(_options: never, _config: Options.Testrunner);
|
16 | /**
|
17 | * nothing to initialize when running locally
|
18 | */
|
19 | initialize(): void;
|
20 | getWorkerCount(): number;
|
21 | run({ command, args, ...workerOptions }: RunArgs): Promise<WorkerInstance>;
|
22 | /**
|
23 | * shutdown all worker processes
|
24 | *
|
25 | * @return {Promise} resolves when all worker have been shutdown or
|
26 | * a timeout was reached
|
27 | */
|
28 | shutdown(): Promise<boolean>;
|
29 | }
|
30 |
|
\ | No newline at end of file |