Struct ClientBuilder 

pub struct ClientBuilder { /* private fields */ }

Builder for configuring and creating a Procwire client.

Use the fluent API to register handlers and events, then call start() to begin the client lifecycle.

Implementations

impl ClientBuilder

pub fn new() -> Self

Create a new client builder.

pub fn handle<F, T, Fut>(self, method: &str, handler: F) -> Self

where F: Fn(T, RequestContext) -> Fut + Send + Sync + 'static, T: DeserializeOwned + Send + 'static, Fut: Future<Output = HandlerResult> + Send + 'static,

Register a method handler with “result” response type.

The handler receives deserialized payload and a context for responding.

pub fn handle_stream<F, T, Fut>(self, method: &str, handler: F) -> Self

where F: Fn(T, RequestContext) -> Fut + Send + Sync + 'static, T: DeserializeOwned + Send + 'static, Fut: Future<Output = HandlerResult> + Send + 'static,

Register a method handler with “stream” response type.

Use ctx.chunk() to send stream chunks and ctx.end() to finish.

pub fn handle_ack<F, T, Fut>(self, method: &str, handler: F) -> Self

where F: Fn(T, RequestContext) -> Fut + Send + Sync + 'static, T: DeserializeOwned + Send + 'static, Fut: Future<Output = HandlerResult> + Send + 'static,

Register a method handler with “ack” response type.

Use ctx.ack() to send the acknowledgment.

pub fn event(self, name: &str) -> Self

Register an event that this client can emit.

Events are fire-and-forget messages to the parent.

pub fn max_concurrent_handlers(self, limit: usize) -> Self

Set the maximum number of concurrent handlers.

When this limit is reached, new requests will be dropped with a warning. Default: 256

pub fn max_pending_frames(self, limit: usize) -> Self

Set the maximum pending frames for backpressure.

When this limit is reached, response methods will wait until backpressure clears or timeout. Default: 1024

pub fn channel_capacity(self, capacity: usize) -> Self

Set the writer channel capacity.

Default: 1024

pub fn backpressure_timeout(self, timeout: Duration) -> Self

Set the backpressure timeout.

Default: 5 seconds

pub async fn start(self) -> Result<Client>

Build and start the client.

This will:

1. Generate pipe path
2. Start pipe listener
3. Send $init to parent (stdout)
4. Accept parent connection
5. Start frame processing loop

Trait Implementations

impl Default for ClientBuilder

fn default() -> Self

Returns the “default value” for a type.