()
| 178 | }) |
| 179 | |
| 180 | const refresh = () => loading.withPermit(load().pipe(Effect.andThen(ctx.catalog.reload()))) |
| 181 | yield* events.subscribe(Integration.Event.ConnectionUpdated).pipe( |
| 182 | Stream.filter((event) => event.data.integrationID === Integration.ID.make("opencode")), |
| 183 | Stream.runForEach(refresh), |