LiveSource

interface LiveSource<P, R = never> {
  readonly entity: string
  readonly subscribe: (context: {
    readonly requirements: ReadonlyArray<Requirement>
    readonly after: number
    readonly principal: P
  }) => Stream.Stream<
    Schema.Schema.Type<typeof LiveChange>,
    RemoteServerError,
    R
  >
}