(value: SystemContext, previous: Snapshot)
| 281 | |
| 282 | /** Creates a complete replacement generation or blocks while admitted context is unavailable. */ |
| 283 | export function replace(value: SystemContext, previous: Snapshot): Effect.Effect<ReplacementResult> { |
| 284 | return observe(value).pipe(Effect.map((entries) => replaceObservation(entries, previous))) |
| 285 | } |
| 286 | |
| 287 | function replaceObservation(entries: ReadonlyArray<Entry>, previous: Snapshot): ReplacementResult { |
| 288 | if (entries.some((entry) => entry._tag === "Unavailable" && getSnapshot(previous, entry.key) !== undefined)) |
no test coverage detected