sark-core 0.25.0

Fiber-free request, route, dispatch, and lifecycle core for Sark
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

//! Static HTTP server carrier boundary.

use crate::{
    life::session,
    manifold::{self, client::event::Reset, schedule, stream},
};

pub mod app;
pub mod drain;
mod event;
pub mod timing;

pub use event::Event;

/// One protocol-native HTTP server connection.
pub trait Connection {
    type Owner: session::Storage;
    type Key: manifold::raw::Key;
    type Block: schedule::Block;
    type Message: stream::Message<Key = Self::Key>;
    type Fields;
    type Selection;
    /// Carrier proof that an emitted field section passed protocol admission.
    type Control;
    type Permit;
    type Data: stream::Payload<Self::Owner, Permit = Self::Permit>;
    type Retired;
    type Output;
    type Error;
    type Writer<'a>: stream::Write<Self::Output, Block = Self::Block, Error = Self::Error>
    where
        Self: 'a;
    type Ready<'a>: drain::Ready<Item = Event<Self>>
    where
        Self: 'a;

    fn has_event(&mut self) -> bool;

    fn ready(&mut self) -> Option<Self::Ready<'_>>;

    fn poll_wake(&mut self) -> Option<schedule::Wake<Self::Key>>;

    fn writer(&mut self, stream: Self::Key) -> Self::Writer<'_>;

    fn reset(&mut self, stream: Self::Key, reason: Reset);

    fn fail(&mut self);
}