Struct age_core::plugin::Connection

pub struct Connection<R: Read, W: Write> { /* private fields */ }

Available on crate feature plugin only.

A connection to a plugin binary.

Implementations

impl Connection<DebugReader<ChildStdout>, DebugWriter<ChildStdin>>

pub fn open(binary: &Path, state_machine: &str) -> Result<Self>

Starts a plugin binary with the given state machine.

If the AGEDEBUG environment variable is set to plugin, then all messages sent to and from the plugin, as well as anything the plugin prints to its stderr, will be printed to the stderr of the parent process.

impl Connection<Stdin, Stdout>

pub fn accept() -> Self

Initialise a connection from an age client.

impl<R: Read, W: Write> Connection<R, W>

pub fn unidir_send<P: FnOnce(UnidirSend<'_, R, W>) -> Result<()>>(
    &mut self,
    phase_steps: P
) -> Result<()>

Runs a unidirectional phase as the controller.

pub fn unidir_receive<A, B, C, E, F, G, H>(
    &mut self,
    command_a: (&str, F),
    command_b: (&str, G),
    command_c: (Option<&str>, H)
) -> Result<(Result<Vec<A>, Vec<E>>, Result<Vec<B>, Vec<E>>, Option<Result<Vec<C>, Vec<E>>>)>where
    F: Fn(Stanza) -> Result<A, E>,
    G: Fn(Stanza) -> Result<B, E>,
    H: Fn(Stanza) -> Result<C, E>,

Runs a unidirectional phase as the recipient.

Arguments

command_a, command_b, and (optionally) command_c are the known commands that are expected to be received. All other received commands (including grease) will be ignored.

pub fn bidir_send<P: FnOnce(BidirSend<'_, R, W>) -> Result<()>>(
    &mut self,
    phase_steps: P
) -> Result<()>

Runs a bidirectional phase as the controller.

pub fn bidir_receive<H>(&mut self, commands: &[&str], handler: H) -> Result<()>where
    H: FnMut(Stanza, Reply<'_, R, W>) -> Response,

Runs a bidirectional phase as the recipient.