glendam/process_call

Performs monitored request-response calls to Gleam processes.

Types

CallError

Represents a monitored process call failure.

pub type CallError {
  CallTimedOut
  CalleeExited(reason: process.ExitReason)
}

Constructors

```
CallTimedOut
```
No reply arrived before the timeout.

CalleeExited(reason: process.ExitReason)

The process exited before replying.

Values

call

</>

pub fn call(
  subject subject: process.Subject(request),
  make_request make_request: fn(process.Subject(response)) -> request,
  within timeout_milliseconds: Int,
) -> Result(response, CallError)

Calls a process and creates a fresh reply subject for the exchange.

call_with_subject

</>

pub fn call_with_subject(
  subject subject: process.Subject(request),
  make_request make_request: fn(process.Subject(response)) -> request,
  reply_subject reply_subject: process.Subject(response),
  within timeout_milliseconds: Int,
) -> Result(response, CallError)

Calls a process using a caller-provided reply subject.