Function write

packages/experimental/src/EventJournal.ts:248–270

({ effect, event, payload, primaryKey })

  return EventJournal.of({
    entries: Effect.sync(() => journal.slice()),
    write({ effect, event, payload, primaryKey }) {
      return Effect.acquireUseRelease(
        Effect.sync(() =>
          new Entry({
            id: makeEntryId(),
            event,
            primaryKey,
            payload
          }, { disableValidation: true })
        ),
        effect,
        (entry, exit) =>
          Effect.suspend(() => {
            if (exit._tag === "Failure" || byId.has(entry.idString)) return Effect.void
            journal.push(entry)
            byId.set(entry.idString, entry)
            remotes.forEach((remote) => {
              remote.missing.push(entry)
            })
            return pubsub.publish(entry)
          })
      )
    },
    writeFromRemote: (options) =>
      Effect.gen(function*() {
        const remote = ensureRemote(options.remoteId)