github/meteor
1
1
Fork 0
mirror of https://github.com/meteor/meteor.git synced 2026-05-02 03:01:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

adjust types

Browse Source
This commit is contained in:
Leonardo Venturini
2024-12-02 10:44:42 -04:00
parent 605faa9129
commit 060799c67a
1 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
packages/mongo/observe_handle.ts
View File

@@ -4,12 +4,15 @@ let nextObserveHandleId = 1;
export type ObserveHandleCallbackInternal = '_added' | '_addedBefore' | '_changed' | '_movedBefore' | '_removed';
export type Callback<T = any> = (...args: T[]) => Promise<void> | void;
/**
* The "observe handle" returned from observeChanges.
* Contains a reference to an ObserveMultiplexer.
* Used to stop observation and clean up resources.
*/
export class ObserveHandle {
export class ObserveHandle<T = any> {
_id: number;
_multiplexer: ObserveMultiplexer;
nonMutatingCallbacks: boolean;
@@ -18,13 +21,13 @@ export class ObserveHandle {
public initialAddsSentResolver: (value: void) => void = () => {};
public initialAddsSent: Promise<void>
_added?: (...args: any[]) => Promise<void>;
_addedBefore?: (...args: any[]) => Promise<void>;
_changed?: (...args: any[]) => Promise<void>;
_movedBefore?: (...args: any[]) => Promise<void>;
_removed?: (...args: any[]) => Promise<void>;
_added?: Callback<T>;
_addedBefore?: Callback<T>;
_changed?: Callback<T>;
_movedBefore?: Callback<T>;
_removed?: Callback<T>;
constructor(multiplexer: any, callbacks: Record<ObserveHandleCallback, any>, nonMutatingCallbacks: boolean) {
constructor(multiplexer: any, callbacks: Record<ObserveHandleCallback, Callback<T>>, nonMutatingCallbacks: boolean) {
this._multiplexer = multiplexer;
multiplexer.callbackNames().forEach((name: ObserveHandleCallback) => {