yujunjun/playwright
1
0
Fork 0
mirror of https://github.com/microsoft/playwright.git synced 2025-06-26 21:40:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: remove unused code (#24167)

Browse Source
This commit is contained in:
Dmitry Gozman 2023-07-11 15:08:05 -07:00 committed by GitHub
parent 8fbcffa43e
commit 76d85c55cf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 134 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

129
packages/playwright-core/src/client/joiningEventEmitter.ts
View File

@ -1,129 +0,0 @@
/**
* Copyright (c) Microsoft Corporation.
*
* Licensed under the Apache License, Version 2.0 (the 'License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import { EventEmitter } from 'events';
import { MultiMap } from '../utils/multimap';
const originalListener = Symbol('originalListener');
const wrapperListener = Symbol('wrapperListener');
export class JoiningEventEmitter implements EventEmitter {
private _emitterDelegate = new EventEmitter();
private _pendingPromises = new MultiMap<string | symbol, Promise<void>>();
addListener(event: string | symbol, listener: (...args: any[]) => void): this {
this._emitterDelegate.addListener(event, this._wrap(event, listener));
return this;
}
on(event: string | symbol, listener: (...args: any[]) => void): this {
this._emitterDelegate.on(event, this._wrap(event, listener));
return this;
}
once(event: string | symbol, listener: (...args: any[]) => void): this {
const onceWrapper = (...args: any) => {
listener(...args);
this.off(event, onceWrapper);
};
this.on(event, onceWrapper);
return this;
}
removeListener(event: string | symbol, listener: (...args: any[]) => void): this {
this._emitterDelegate.removeListener(event, this._wrapper(listener));
return this;
}
off(event: string | symbol, listener: (...args: any[]) => void): this {
this._emitterDelegate.off(event, this._wrapper(listener));
return this;
}
removeAllListeners(event?: string | symbol | undefined): this {
this._emitterDelegate.removeAllListeners(event);
return this;
}
setMaxListeners(n: number): this {
this._emitterDelegate.setMaxListeners(n);
return this;
}
getMaxListeners(): number {
return this._emitterDelegate.getMaxListeners();
}
listeners(event: string | symbol): Function[] {
return this._emitterDelegate.listeners(event).map(f => this._original(f));
}
rawListeners(event: string | symbol): Function[] {
return this._emitterDelegate.rawListeners(event).map(f => this._original(f));
}
emit(event: string | symbol, ...args: any[]): boolean {
return this._emitterDelegate.emit(event, ...args);
}
listenerCount(event: string | symbol): number {
return this._emitterDelegate.listenerCount(event);
}
prependListener(event: string | symbol, listener: (...args: any[]) => void): this {
this._emitterDelegate.prependListener(event, this._wrap(event, listener));
return this;
}
prependOnceListener(event: string | symbol, listener: (...args: any[]) => void): this {
const onceWrapper = (...args: any) => {
listener(...args);
this.off(event, onceWrapper);
};
this.prependListener(event, onceWrapper);
return this;
}
eventNames(): (string | symbol)[] {
return this._emitterDelegate.eventNames();
}
async _joinPendingEventHandlers() {
await Promise.all([...this._pendingPromises.values()]);
}
private _wrap(event: string | symbol, listener: (...args: any[]) => void) {
const wrapper = (...args: any) => {
const result = listener(...args) as any;
if (result instanceof Promise) {
this._pendingPromises.set(event, result);
result.finally(() => this._pendingPromises.delete(event, result));
}
};
(wrapper as any)[originalListener] = listener;
(listener as any)[wrapperListener] = wrapper;
return wrapper;
}
private _wrapper(listener: (...args: any[]) => void) {
// Fallback to original listener if not wrapped to ensure backwards compatibility Node.js's event emitter
return (listener as any)[wrapperListener] ?? listener;
}
private _original(wrapper: Function): Function {
return (wrapper as any)[originalListener];
}
}

7
packages/playwright-test/src/index.ts
View File

@ -56,7 +56,6 @@ type TestFixtures = PlaywrightTestArgs & PlaywrightTestOptions & {
type WorkerFixtures = PlaywrightWorkerArgs & PlaywrightWorkerOptions & {
_browserOptions: LaunchOptions;
_artifactsDir: () => string;
_snapshotSuffix: string;
};
const playwrightFixtures: Fixtures<TestFixtures, WorkerFixtures> = ({
@ -245,12 +244,10 @@ const playwrightFixtures: Fixtures<TestFixtures, WorkerFixtures> = ({
});
},
_snapshotSuffix: [process.platform, { scope: 'worker' }],
_setupContextOptions: [async ({ playwright, _snapshotSuffix, _combinedContextOptions, _artifactsDir, actionTimeout, navigationTimeout, testIdAttribute }, use, testInfo) => {
_setupContextOptions: [async ({ playwright, _combinedContextOptions, _artifactsDir, actionTimeout, navigationTimeout, testIdAttribute }, use, testInfo) => {
if (testIdAttribute)
playwrightLibrary.selectors.setTestIdAttribute(testIdAttribute);
testInfo.snapshotSuffix = _snapshotSuffix;
testInfo.snapshotSuffix = process.platform;
if (debugMode())
testInfo.setTimeout(0);
for (const browserType of [playwright.chromium, playwright.firefox, playwright.webkit]) {