fix kashkool
This commit is contained in:
@@ -3,10 +3,15 @@ import type { Product } from '@/models/products'
|
||||
type ProductListHandler = (products: Product[]) => void
|
||||
|
||||
const handlers = new Set<ProductListHandler>()
|
||||
let lastProductsList: Product[] | null = null
|
||||
|
||||
export function subscribeProductListStream(handler: ProductListHandler) {
|
||||
handlers.add(handler)
|
||||
|
||||
if (lastProductsList?.length) {
|
||||
handler(lastProductsList)
|
||||
}
|
||||
|
||||
return () => {
|
||||
handlers.delete(handler)
|
||||
}
|
||||
@@ -17,5 +22,10 @@ export function applyProductsListFromStream(products: Product[]) {
|
||||
return
|
||||
}
|
||||
|
||||
lastProductsList = products
|
||||
handlers.forEach((handler) => handler(products))
|
||||
}
|
||||
|
||||
export function getLastStreamProductsList(): Product[] | null {
|
||||
return lastProductsList
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user