mirror of
https://github.com/Chevron7Locked/kima-hub.git
synced 2026-06-19 07:37:17 +00:00
81ac1b5c17
ensureSubscriber duplicated the parent Redis client, inheriting enableOfflineQueue:false + maxRetriesPerRequest:0, so psubscribe threw 'Stream isn't writeable' when the subscriber socket wasn't connected yet -- and the rejected promise was cached, breaking vibe text search permanently until restart (worsens with library size). The subscriber now gets its own offline queue + retries, resets the cached promise on rejection, and drops it on 'end' so the next request reconnects.