fix: 修复waitFor无法等待一个retain=true消息的问题

Author: zhangfisher

packages/native/src/__tests__/waitFor.test.ts

@@ -203,6 +203,23 @@ describe("waitfor", () => {
 
     });
 
+    test('等待retain事件时马上返回', async () => {
+        const emitter = new FastEvent();
+
+        emitter.emit("x", 1, true)
+
+        // Arrange
+        const results = await emitter.waitFor('x', 500);
+
+        expect(results).toEqual({
+            type: 'x',
+            payload: 1,
+            meta: undefined
+        });
+
+
+    });
+
 
 
 })

packages/native/src/event.ts

@@ -868,7 +868,7 @@ export class FastEvent<
             let subscriber: FastEventSubscriber
             const listener = (message: TypedFastEventMessage<AllEvents, Meta>) => {
                 clearTimeout(tid)
-                subscriber.off()
+                subscriber && subscriber.off()
                 resolve(message)
             }
             if (timeout && timeout > 0) {