effect-tea-persistent
    Preparing search index...
    • Sends an inbound message to another entity from an operation, and waits for the reply. The request is the run of the operation and name, which names it among those the operation makes (decisions 0047, 0060). So a restarted operation sends the same requests, and gets the stored replies, and the NotFound the run before it was given (decision 0253). One that sends twice under the same name to the same entity dies. While the receiver is suspended, it waits, and it sends again when the receiver crashes (decision 0046). It sends again too when the receiver holds as many callers' messages as its bound, and is never given Full (decision 0147). Once the operation's entity crashes, the run sends nothing: a send dies, and a send that waits, in a finalizer or in a region held uninterruptible, ends with the defect. The next run of the entity sends under the same request again (decision 0274).

      Type Parameters

      • T extends Readonly<
            {
                flags: unknown;
                inbound: unknown;
                index: string;
                internal: unknown;
                key: string;
                operation: Readonly<{ _tag: string }>;
                parameter: object;
                projection: unknown;
                rejection: unknown;
                sender: unknown;
                services: unknown;
                state: object;
                topics?: Readonly<Record<string, Json>>;
            },
        >

      Parameters

      • program: Receiver<T>
      • id: string
      • message: T["inbound"]
      • name: string

      Returns Effect<Reply<T["rejection"]>, never, Entities>