(tag: Tag, payload: Uint8Array)
| 589 | effect: Effect.fnUntraced(function*({ entries, write }): Effect.fn.Return<void> { |
| 590 | const isEventTag = (tag: string): tag is Event.Tag<Events> => Object.hasOwn(group.events, tag) |
| 591 | const decodePayload = <Tag extends Event.Tag<Events>>(tag: Tag, payload: Uint8Array) => |
| 592 | Schema.decodeUnknownEffect(group.events[tag].payloadMsgPack)(payload).pipe( |
| 593 | Effect.updateContext((input) => Context.merge(services, input)), |
| 594 | Effect.orDie |
| 595 | ) as unknown as Effect.Effect<Event.PayloadWithTag<Events, Tag>> |
| 596 | const writePayload = Effect.fnUntraced(function*<Tag extends Event.Tag<Events>>( |
| 597 | timestamp: number, |
| 598 | tag: Tag, |
no test coverage detected