(id: WorkspaceV2.ID, status: ConnectionStatus["status"])
| 166 | const syncFibers = yield* FiberMap.make<WorkspaceV2.ID, void, SyncLoopError>() |
| 167 | |
| 168 | const setStatus = (id: WorkspaceV2.ID, status: ConnectionStatus["status"]) => { |
| 169 | const prev = connections.get(id) |
| 170 | if (prev?.status === status) return |
| 171 | const next = { workspaceID: id, status } |
| 172 | connections.set(id, next) |
| 173 | |
| 174 | GlobalBus.emit("event", { |
| 175 | directory: "global", |
| 176 | workspace: id, |
| 177 | payload: { |
| 178 | type: Event.Status.type, |
| 179 | properties: next, |
| 180 | }, |
| 181 | }) |
| 182 | } |
| 183 | |
| 184 | const connectSSE = Effect.fn("Workspace.connectSSE")(function* ( |
| 185 | url: URL | string, |
no test coverage detected