(lastReceivedMessage: Message.IncomingRequest<any>)
| 608 | interrupts: Map<Snowflake.Snowflake, Message.IncomingEnvelope> |
| 609 | }>() |
| 610 | const resumeEntityFromStorage = (lastReceivedMessage: Message.IncomingRequest<any>) => { |
| 611 | const address = lastReceivedMessage.envelope.address |
| 612 | const resumptionState = MutableHashMap.get(entityResumptionState, address) |
| 613 | if (Option.isSome(resumptionState)) { |
| 614 | resumptionState.value.unprocessed.add(lastReceivedMessage.envelope.requestId) |
| 615 | return Effect.void |
| 616 | } |
| 617 | MutableHashMap.set(entityResumptionState, address, { |
| 618 | unprocessed: new Set([lastReceivedMessage.envelope.requestId]), |
| 619 | interrupts: new Map() |
| 620 | }) |
| 621 | return resumeEntityFromStorageImpl(address) |
| 622 | } |
| 623 | const resumeEntityFromStorageImpl = Effect.fnUntraced( |
| 624 | function*(address: EntityAddress) { |
| 625 | const state = entityManagers.get(address.entityType) |
no test coverage detected