(error: EntityNotAssignedToRunner)
| 1102 | const shouldFail = !discard && |
| 1103 | (message._tag === "OutgoingRequest" || message.envelope._tag === "AckChunk") |
| 1104 | const abandon = (error: EntityNotAssignedToRunner) => { |
| 1105 | if (!isPersisted) { |
| 1106 | return shouldFail |
| 1107 | ? Effect.fail(error) |
| 1108 | : Effect.logDebug("Abandoning outgoing message during shutdown", message.envelope.address) |
| 1109 | } |
| 1110 | const persist = message._tag === "OutgoingRequest" |
| 1111 | ? storage.saveRequest(message) |
| 1112 | : storage.saveEnvelope(message) |
| 1113 | return Effect.catchTag(persist, "MalformedMessage", Effect.die).pipe( |
| 1114 | Effect.andThen( |
| 1115 | shouldFail |
| 1116 | ? Effect.fail(error) |
| 1117 | : Effect.logWarning("Persisting outgoing message abandoned during shutdown", message.envelope.address) |
| 1118 | ) |
| 1119 | ) |
| 1120 | } |
| 1121 | return Effect.catchFilter( |
| 1122 | Effect.suspend(() => { |
| 1123 | const address = message.envelope.address |
no test coverage detected