Function StreamResponseChunk

packages/effect-app/src/rpc/Invalidation.ts:99–104

(success: S)

 * accumulated since the last drain (V3: mid-stream invalidation).
 */
export const StreamResponseChunk = <S extends S.Top>(success: S) =>
  S.Union([
    S.Struct({ _tag: S.Literal("value"), value: success }),
    S.Struct({ _tag: S.Literal("metadata"), metadata: CommandMetaData }),
    S.Struct({ _tag: S.Literal("done"), metadata: CommandMetaData })
  ])

export type StreamResponseChunk<A> =
  | { readonly _tag: "value"; readonly value: A }