orpc-procedure 1.1.0

Type-erased execution engine for orpc-rs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

# orpc-procedure

Type-erased execution engine for oRPC procedures.

## Overview

This is the lowest-level crate in the orpc-rs stack. It defines the core abstractions that all other crates build upon:

- **`ErasedProcedure<TCtx>`** — A type-erased procedure that accepts dynamic input and produces a `ProcedureStream`
- **`ProcedureStream`** — Unified output type supporting both single-value (`from_future`) and streaming (`from_stream`) results
- **`DynInput` / `DynOutput`** — Type-erased wrappers for serde-compatible values
- **`ErasedSchema`** — Trait for type-erased input/output schemas (extended by `orpc-specta`)

## Usage

Most users should use the higher-level `orpc` crate instead. This crate is useful for:

- Building custom integrations (server adapters, client code generators)
- Working with procedures after type erasure
- Implementing custom schema adapters

```rust
use orpc_procedure::*;

let proc = ErasedProcedure::new(
    |ctx: MyCtx, input: DynInput| {
        ProcedureStream::from_future(async move {
            let name: String = input.deserialize()?;
            Ok(DynOutput::new(format!("Hello, {name}!")))
        })
    },
    Route::default(),
    Meta::default(),
);
```