@@ -45,7 +45,7 @@ implements QueryClientService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
get run(): Effect.Effect<void> {
|
get run(): Effect.Effect<void> {
|
||||||
return Effect.repeat(
|
return this.runSemaphore.withPermits(1)(Effect.repeat(
|
||||||
Effect.andThen(
|
Effect.andThen(
|
||||||
DateTime.now,
|
DateTime.now,
|
||||||
now => SubscriptionRef.update(this.cache, HashMap.filter(entry =>
|
now => SubscriptionRef.update(this.cache, HashMap.filter(entry =>
|
||||||
@@ -56,7 +56,7 @@ implements QueryClientService {
|
|||||||
)),
|
)),
|
||||||
),
|
),
|
||||||
Schedule.spaced("30 second"),
|
Schedule.spaced("30 second"),
|
||||||
)
|
))
|
||||||
}
|
}
|
||||||
|
|
||||||
getCacheEntry(key: QueryClientCacheKey): Effect.Effect<Option.Option<QueryClientCacheEntry>> {
|
getCacheEntry(key: QueryClientCacheKey): Effect.Effect<Option.Option<QueryClientCacheEntry>> {
|
||||||
|
|||||||
Reference in New Issue
Block a user