proxima-primitives 0.1.0

The pipe algebra itself: the Pipe trait — an async In -> Result<Out, Err> that becomes a transform, source, sink or observe by choice of types — plus its three tier siblings (SendPipe, UnpinPipe, UnpinSendPipe), Handler, SourcePipe, the payload types Carry, ResponseStream and RequestStream (buffered bodies are plain Bytes), HeaderList, the sans-IO byte-stream traits, runtime-agnostic concurrency primitives, and the Replay/GenericStream transport seam. Everything else in proxima composes what is defined here.
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

//! Plugin registration trait surface. Used by external plugin crates to
//! register pipe factories without depending on the umbrella `proxima`
//! crate. `AppBuilder` in the umbrella implements this trait so the
//! existing `plugin::register(app_builder)` call sites keep working.

#![cfg(feature = "alloc")]

use proxima_core::ProximaError;

use crate::pipe::pipe_factory::DynPipeFactory;

/// Surface a plugin can register against. Equivalent to the relevant
/// subset of methods on `AppBuilder` in the umbrella `proxima` crate.
/// Adding methods here is breaking; keep the surface minimal.
pub trait PluginRegistry: Sized {
    /// Register a pipe factory under the name embedded in the factory.
    /// Returns the builder with the factory registered. Errors if a
    /// factory with the same name is already registered.
    ///
    /// # Errors
    /// Returns `ProximaError` if registration fails (duplicate name,
    /// invalid factory shape, etc.).
    fn with_upstream_factory(self, factory: DynPipeFactory) -> Result<Self, ProximaError>;
}