Struct SubprocListen

pub struct SubprocListen { /* private fields */ }

An event source that runs a subprocess and generates events for lines of output.

This event source will run a command as a subprocess, generate ListenEvent::Line events for every line it prints to stdout, and one final ListenEvent::End event when it ends.

Processes that run indefinitely can be killed (using SIGKILL ie. 9 on Linux) by returning true from the callback provided to process_events() or by calling the kill() method. Note that there may be more Line events generated after this, depending on the order in which the kill request and remaining output are processed.

After the subprocess has been ended and the final End event has been delivered, this event source should be removed from the event loop.

Implementations

impl SubprocListen

pub fn new(command: Command) -> Result<Self>

Takes a command and schedules a subprocess to be run asychronously.

See the note on the root module regarding the trait bounds if they’re confusing.

pub fn kill(&mut self)

Trait Implementations

impl EventSource for SubprocListen

type Event = ListenEvent

The type of events generated by your source.

type Metadata = ()

Some metadata of your event source

type Ret = bool

The return type of the user callback

type Error = LaunchError

The error type returned from process_events() (not the user callback!).

fn process_events<F>( &mut self, readiness: Readiness, token: Token, callback: F, ) -> Result<PostAction, Self::Error>

where F: FnMut(Self::Event, &mut Self::Metadata) -> Self::Ret,

Process any relevant events

fn register( &mut self, poll: &mut Poll, token_factory: &mut TokenFactory, ) -> Result<()>

Register yourself to this poll instance

fn reregister( &mut self, poll: &mut Poll, token_factory: &mut TokenFactory, ) -> Result<()>

Re-register your file descriptors

fn unregister(&mut self, poll: &mut Poll) -> Result<()>

Unregister your file descriptors

fn pre_run<F>(&mut self, _callback: F) -> Result<(), Error>

where F: FnMut(Self::Event, &mut Self::Metadata) -> Self::Ret,

Notification that a polling session is going to start

fn post_run<F>(&mut self, _callback: F) -> Result<(), Error>

where F: FnMut(Self::Event, &mut Self::Metadata) -> Self::Ret,

Notification that the current polling session ended