Function writePayload

packages/experimental/src/EventLog.ts:284–297

(timestamp: number, tag: string, payload: any)

      events: Object.keys(group.events),
      effect: Effect.fnUntraced(function*({ entries, write }) {
        const writePayload = (timestamp: number, tag: string, payload: any) =>
          Effect.gen(function*() {
            const event = group.events[tag] as any as Event.AnyWithProps
            const entry = new Entry({
              id: makeEntryId({ msecs: timestamp }),
              event: tag,
              payload: yield* (Schema.encode(event.payloadMsgPack)(payload).pipe(
                Effect.locally(FiberRef.currentContext, context),
                Effect.orDie
              ) as Effect.Effect<Uint8Array>),
              primaryKey: event.primaryKey(payload)
            }, { disableValidation: true })
            yield* write(entry)
          })

        const byPrimaryKey = new Map<
          string,