Function publish

packages/infra/src/ClusterServiceBus.ts:113–121

(message: Message.Outgoing<R>)

  yield* Scope.addFinalizer(scope, Effect.promise(() => sender.close()).pipe(Effect.ignore))

  const publish = <R extends Rpc.Any>(message: Message.Outgoing<R>) =>
    Effect
      .tryPromise({
        try: () => sender.sendMessages(storageNotification(message)),
        catch: (cause) => new ServiceBusPublishError({ cause })
      })
      .pipe(
        Effect.catch((cause) => Effect.logDebug("Could not publish cluster storage notification", cause))
      )

  return yield* Runners.make({
    ping: (address) => Effect.fail(new ClusterError.RunnerUnavailable({ address })),