|
1 | 1 | /// <reference lib="dom" />
|
2 | 2 | import { LS_DEV, shouldNeverHappen, TRACE_VERBOSE } from '@livestore/utils'
|
3 |
| -import { Option, type Runtime, type Scope } from '@livestore/utils/effect' |
4 |
| -import { BucketQueue, Effect, FiberHandle, Queue, Schema, Stream, Subscribable } from '@livestore/utils/effect' |
| 3 | +import { |
| 4 | + BucketQueue, |
| 5 | + Effect, |
| 6 | + FiberHandle, |
| 7 | + Option, |
| 8 | + Queue, |
| 9 | + type Runtime, |
| 10 | + Schema, |
| 11 | + type Scope, |
| 12 | + Stream, |
| 13 | + Subscribable, |
| 14 | +} from '@livestore/utils/effect' |
5 | 15 | import * as otel from '@opentelemetry/api'
|
6 | 16 |
|
7 | 17 | import { type ClientSession, SyncError, type UnexpectedError } from '../adapter-types.js'
|
@@ -115,13 +125,13 @@ export const makeClientSessionSyncProcessor = ({
|
115 | 125 | )
|
116 | 126 |
|
117 | 127 | if (mergeResult._tag === 'unexpected-error') {
|
118 |
| - return yield* new SyncError({ cause: mergeResult.message }) |
| 128 | + return shouldNeverHappen('Unexpected error in client-session-sync-processor', mergeResult.message) |
119 | 129 | }
|
120 | 130 |
|
121 | 131 | if (TRACE_VERBOSE) yield* Effect.annotateCurrentSpan({ mergeResult: JSON.stringify(mergeResult) })
|
122 | 132 |
|
123 | 133 | if (mergeResult._tag !== 'advance') {
|
124 |
| - return yield* new SyncError({ cause: `Expected advance, got ${mergeResult._tag}` }) |
| 134 | + return shouldNeverHappen(`Expected advance, got ${mergeResult._tag}`) |
125 | 135 | }
|
126 | 136 |
|
127 | 137 | syncStateRef.current = mergeResult.newSyncState
|
@@ -346,7 +356,7 @@ export interface ClientSessionSyncProcessor {
|
346 | 356 | {
|
347 | 357 | writeTables: Set<string>
|
348 | 358 | },
|
349 |
| - SyncError |
| 359 | + never |
350 | 360 | >
|
351 | 361 | boot: Effect.Effect<void, UnexpectedError, Scope.Scope>
|
352 | 362 | /**
|
|
0 commit comments