Function serializeOrDefect

packages/effect/src/unstable/cluster/Reply.ts:443–455

(
  self: ReplyWithContext<R>
)

 * @since 4.0.0
 */
export const serializeOrDefect = <R extends Rpc.Any>(
  self: ReplyWithContext<R>
): Effect.Effect<Encoded> =>
  Effect.catchTag(
    serialize(self),
    "MalformedMessage",
    (error) =>
      Effect.orDie(serialize(ReplyWithContext.fromDefect({
        id: self.reply.id,
        requestId: self.reply.requestId,
        defect: error
      })))
  )

/**
 * Serializes an outgoing request's last received reply when one exists, returning