Struct Connection

pub struct Connection { /* private fields */ }

A handle to a running command server instance.

Implementations

impl Connection

pub fn new() -> Result<Connection>

Spawns a new command server process.

pub fn read_hello(&mut self) -> Result<(Vec<String>, String)>

Reads and parses the server hello message. Returns a tuple of ([capabilities], encoding).

Errors

Returns an I/O error if reading or parsing the hello message failed.

pub fn raw_command(&mut self, command: Vec<&[u8]>) -> Result<CommandRun<'_>>

Sends the given command to Mercurial, returning an iterator over the results.

Examples found in repository

examples/client.rs (line 9)

fn run_command(cmdserver: &mut CommandServer, command: Vec<&[u8]>) -> (i32, Vec<u8>, Vec<u8>) {
    let (mut result, mut output, mut error) =
        (-1i32, vec![], vec![]);
    let run = cmdserver.connection
        .raw_command(command)
        .ok().expect("failed to send 'log' command");

    for chunk in run {
        match chunk {
            Ok(Chunk::Output(s)) => output.extend(s),
            Ok(Chunk::Error(s)) => error.extend(s),
            Ok(Chunk::Result(r)) => { result = r },
            Ok(_) => unimplemented!(),
            Err(e) => panic!("failed to read command results: {}", e),
        }
    }

    (result, output, error)
}

pub fn close(&mut self) -> Result<ExitStatus>

Shuts down the command server process.

Examples found in repository

examples/client.rs (line 32)

fn main() {
    let mut cmdserver = CommandServer::new().ok().expect("failed to start command server");
    println!("capabilities: {:?}", cmdserver.capabilities);
    println!("encoding: {:?}", cmdserver.encoding);

    let (result, output, error) =
        run_command(&mut cmdserver, vec![b"log", b"-l", b"5"]);
    cmdserver.connection.close().ok().expect("command server did not stop cleanly");

    println!("output: {}",
             String::from_utf8(output).unwrap().trim_right_matches('\n'));
    println!("error: {}",
             String::from_utf8(error).unwrap().trim_right_matches('\n'));
    println!("result: {:?}", result);
}