fix(signal): 多个初始 get 表现正常

src/utils/signal.test.ts

@@ -20,4 +20,19 @@ describe('signal', () => {
     userData.throw('err')
     await expect(userData.get()).rejects.toContain('err')
   })
+
+  test('多个初始 get 表现正常', async () => {
+    let _userData = ''
+    let _userData2 = ''
+    const userData = signal<string>()
+    userData.get().then(v => (_userData = v))
+    userData.get().then(v => (_userData2 = v))
+    await wait(0)
+    expect(_userData).toBe('')
+    expect(_userData2).toBe('')
+    userData.set('test')
+    await wait(0)
+    expect(_userData).toBe('test')
+    expect(_userData2).toBe('test')
+  })
 })

src/utils/signal.ts

@@ -14,26 +14,26 @@ export function signal<T>(): SignalResult<T> {
   let error!: any
   let isException = false
 
-  let $resolve: any
-  let $reject: any
+  const $resolve: any[] = []
+  const $reject: any[] = []
 
   const setValue: SignalResult<T>['set'] = _value => {
     value = _value
-    if ($resolve) {
-      $resolve(value)
-      $resolve = null
-      $reject = null
+    if ($resolve.length) {
+      $resolve.forEach(resolve => resolve(value))
+      $resolve.length = 0
+      $reject.length = 0
     }
     isOk = true
     isException = false
   }
 
   const throwError: SignalResult<T>['throw'] = _error => {
     error = _error
-    if ($reject) {
-      $reject(error)
-      $resolve = null
-      $reject = null
+    if ($reject.length) {
+      $reject.forEach(reject => reject(error))
+      $resolve.length = 0
+      $reject.length = 0
     }
     isOk = false
     isException = true
@@ -53,8 +53,8 @@ export function signal<T>(): SignalResult<T> {
       if (isException) {
         return reject(error)
       }
-      $resolve = resolve
-      $reject = reject
+      $resolve.push(resolve)
+      $reject.push(reject)
     })
   }