rutis 0.6.1

Cordis core paradigms in idiomatic Rust: plugin assembly, fiber lifecycle, typed service registry, dependency-driven reload
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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

//! rutis: Cordis 核心范式的 Rust 惯用实现。
//!
//! 五支柱(设计文档 §一):
//! 1. 插件 = 装配单元(一次 `apply`,提供服务/监听/清理)
//! 2. fiber = 生命周期容器(六态状态机 + 依赖门控 + 级联卸载 + 恰好一次清理)
//! 3. 服务 = 类型键注册表 + isolate 作用域
//! 4. 事件总线 = 四分发语义(emit/parallel/serial/waterfall)
//! 5. 依赖驱动重载(provider 卸载 → 消费者驱逐并自动重载)

#![allow(clippy::type_complexity)]

mod bus;
mod ctx;
mod diagnostics;
mod effect;
mod error;
mod event;
mod fiber;
mod intercept;
mod key;
mod plugin;
mod registry;
mod typed;

pub use bus::{DispatchAttempt, DispatchMode, EventBus, EventSubscription, ListenerKind};
pub use ctx::Ctx;
pub use diagnostics::{
    BindingDiagnostics, DependencyDiagnostics, DependencyStatus, EventBacklog, PluginDiagnostics,
    ResolvedDependency, RuntimeDiagnostics, ServiceAccess, ServiceChange, ServiceChanged,
};
pub use effect::{Disposer, Effect, EffectMeta, EffectPhase};
pub use error::{
    CordisError, ErrorSink, ServiceReadError, ServiceReadFailure, ServiceWriteError,
    ServiceWriteFailure,
};
pub use event::{
    Event, EventOptions, Listener, Next, PatternListener, PatternWaterfallListener, Terminal,
    WaterfallListener,
};
pub use event::{
    SyncEvent, SyncListener, SyncNext, SyncPatternListener, SyncPatternWaterfallListener,
    SyncWaterfallListener,
};
pub use fiber::{DisposeWaitError, FiberState, FiberStatusChanged, FiberView, PluginId, Snapshot};
pub use intercept::{ServiceIntercept, ServiceWriter};
pub use key::{EventKey, EventPattern, InstanceId, Key, ServiceKey, TypeKey};
pub use plugin::{Plugin, PluginFactory};
pub use typed::{
    DepKey, Deps, Gate, Keyed, KeyedGate, Typed, TypedFactory, TypedPlugin, TypedPluginFactory,
};

/// dyn 兼容的 future 别名(与 `futures::future::BoxFuture` 同一定义,D1)。
pub type BoxFuture<'a, T> = std::pin::Pin<Box<dyn std::future::Future<Output = T> + Send + 'a>>;

/// The development handbook's Rust examples compile against this crate.
#[cfg(doctest)]
#[doc = include_str!("../../../docs/development-handbook.md")]
pub struct DevelopmentHandbook;