intrepid-core 0.1.2

Manage complex async business logic with ease
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use crate::{Frame, MessageFrame};

use super::{
    extractor_error::{MessageFrameError, WrongFrameError},
    ExtractContext, Extractor,
};

#[derive(Clone, Debug)]
/// Retrieve a [`MessageFrame`] from a [`Frame`], but only if the frame is a message.
pub struct Message(pub MessageFrame);

impl<State> Extractor<State> for Message {
    type Error = MessageFrameError;

    fn extract(frame: Frame, _: &ExtractContext<State>) -> Result<Self, Self::Error> {
        match frame {
            Frame::Message(message) => Ok(Self(message)),
            _ => Err(WrongFrameError.into()),
        }
    }
}