rskit-provider — Async I/O Interaction Traits

Typed async interaction traits (Provider, RequestResponse, Stream, Sink, Duplex) with a Tower bridge.

Features

• RequestResponse<I,O> — single request → single response
• Stream<I,O> — request → async stream of responses
• Sink<I> — fire-and-forget
• Duplex<I,O> — bidirectional streaming
• Tower bridge for adapting tower::Service to RequestResponse

The provider traits intentionally remain object-safe via async-trait because some downstream adapters store them behind dyn trait objects. Stream, sink, and duplex implementations must use bounded queues or downstream backpressure and surface saturation as typed AppError values.

Cross-cutting behavior such as retry, rate limiting, circuit breaking, logging, and tracing belongs above these L2 contracts. Compose those concerns with rskit-resilience tower layers before wrapping a service with TowerProvider.

Usage

[dependencies]
rskit-provider = "0.2.0-alpha.3"
async-trait = "0.1"

use rskit_provider::{Provider, RequestResponse};

struct EchoProvider;

#[async_trait::async_trait]
impl Provider for EchoProvider {
    fn name(&self) -> &'static str {
        "echo"
    }
}

#[async_trait::async_trait]
impl RequestResponse<String, String> for EchoProvider {
    async fn execute(&self, input: String) -> rskit_errors::AppResult<String> {
        Ok(input.to_uppercase())
    }
}

See Also

Main repository README