Struct ockam_channel::SecureChannelDecryptor

pub struct SecureChannelDecryptor<V: SecureChannelVault, K: SecureChannelKeyExchanger> { /* private fields */ }

Secure Channel Decryptor

Implementations

impl<V: SecureChannelVault, K: SecureChannelKeyExchanger> SecureChannelDecryptor<V, K>

pub async fn new_responder(
    key_exchanger: K,
    key_exchange_completed_callback_route: Option<Address>,
    vault: V
) -> Result<Self>

New responder

Trait Implementations

impl<V: SecureChannelVault, K: SecureChannelKeyExchanger> Worker for SecureChannelDecryptor<V, K>

type Message = Any

The type of Message the Worker is sent in Self::handle_message.

type Context = Context

The API and other resources available for the worker during message processing.

fn initialize<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    ctx: &'life1 mut Self::Context
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Override initialisation behaviour.

fn handle_message<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    ctx: &'life1 mut Self::Context,
    msg: Routed<Self::Message>
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Try to open and handle a typed message.

fn shutdown<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _context: &'life1 mut Self::Context
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Override shutdown behaviour.

fn is_authorized<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _context: &'life1 mut Self::Context,
    _msg: Routed<Self::Message>
) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait, Global>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Try to authorize an incoming message