gproxy-protocol 4.1.14

GPROXY v4 connection modelling, operation declarations, vendor wire types and pairwise conversion
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

use super::*;

/// Concrete child advancement only; wire events remain the selected pair's types.
pub(super) trait ChildNext<B: FanoutBridge, S: StateStore> {
    async fn next(
        &mut self,
        child: &mut StreamInvocation<B>,
        index: usize,
        state: &GenerationStateAccess<'_, S>,
    ) -> Result<Option<StreamChunk<B::ClientEvent>>, TransformError>;
}

pub(super) struct Plain;

impl<B: FanoutBridge, S: StateStore> ChildNext<B, S> for Plain {
    async fn next(
        &mut self,
        child: &mut StreamInvocation<B>,
        _: usize,
        state: &GenerationStateAccess<'_, S>,
    ) -> Result<Option<StreamChunk<B::ClientEvent>>, TransformError> {
        child.next(state).await
    }
}