guardia-messenger/node_modules/expo-modules-core/src/EventEmitter.ts
DESKTOP-TKLFCPRython f29f525c77 refactor: 101.79.17.164 → zioinfo.co.kr 전체 도메인 변환 + Manager UI 배포
- 37개 파일 IP → zioinfo.co.kr 치환 (소스/매뉴얼/설정/하네스)
- Manager DrConsole/NetworkConsole/CsapConsole 빌드 + /var/www/manager/ 배포
- 테스트: Manager HTTP 200, ITSM 신규 API 7개 전체 200

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-05-31 10:09:17 +09:00

107 lines
3.3 KiB
TypeScript

import invariant from 'invariant';
import { NativeEventEmitter, Platform } from 'react-native';
const nativeEmitterSubscriptionKey = '@@nativeEmitterSubscription@@';
type NativeModule = {
__expo_module_name__?: string;
startObserving?: () => void;
stopObserving?: () => void;
// Erase these types as they would conflict with the new NativeModule type.
// This EventEmitter is deprecated anyway.
addListener?: any;
removeListeners?: any;
};
// @needsAudit
export type Subscription = {
/**
* A method to unsubscribe the listener.
*/
remove: () => void;
};
export class EventEmitter {
_listenerCount = 0;
// @ts-expect-error
_nativeModule: NativeModule;
// @ts-expect-error
_eventEmitter: NativeEventEmitter;
constructor(nativeModule: NativeModule) {
// If the native module is a new module, just return it back as it's already an event emitter.
// This is for backwards compatibility until we stop using this legacy class in other packages.
if (nativeModule.__expo_module_name__) {
// @ts-expect-error
return nativeModule;
}
this._nativeModule = nativeModule;
this._eventEmitter = new NativeEventEmitter(nativeModule as any);
}
addListener<T>(eventName: string, listener: (event: T) => void): Subscription {
if (!this._listenerCount && Platform.OS !== 'ios' && this._nativeModule.startObserving) {
this._nativeModule.startObserving();
}
this._listenerCount++;
const nativeEmitterSubscription = this._eventEmitter.addListener(eventName, listener);
const subscription = {
[nativeEmitterSubscriptionKey]: nativeEmitterSubscription,
remove: () => {
this.removeSubscription(subscription);
},
};
return subscription;
}
removeAllListeners(eventName: string): void {
// @ts-ignore: the EventEmitter interface has been changed in react-native@0.64.0
const removedListenerCount = this._eventEmitter.listenerCount
? // @ts-ignore: this is available since 0.64
this._eventEmitter.listenerCount(eventName)
: // @ts-ignore: this is available in older versions
this._eventEmitter.listeners(eventName).length;
this._eventEmitter.removeAllListeners(eventName);
this._listenerCount -= removedListenerCount;
invariant(
this._listenerCount >= 0,
`EventEmitter must have a non-negative number of listeners`
);
if (!this._listenerCount && Platform.OS !== 'ios' && this._nativeModule.stopObserving) {
this._nativeModule.stopObserving();
}
}
removeSubscription(subscription: Subscription): void {
const nativeEmitterSubscription = subscription[nativeEmitterSubscriptionKey];
if (!nativeEmitterSubscription) {
return;
}
if ('remove' in nativeEmitterSubscription) {
nativeEmitterSubscription.remove();
}
this._listenerCount--;
// Ensure that the emitter's internal state remains correct even if `removeSubscription` is
// called again with the same subscription
delete subscription[nativeEmitterSubscriptionKey];
// Release closed-over references to the emitter
subscription.remove = () => {};
if (!this._listenerCount && Platform.OS !== 'ios' && this._nativeModule.stopObserving) {
this._nativeModule.stopObserving();
}
}
emit(eventName: string, ...params: any[]): void {
this._eventEmitter.emit(eventName, ...params);
}
}