fn send_all_commands(&self, cmds: &[Cmd]) -> RedisResult<Vec<NodeCmd>> {
        let mut connections = self.connections.borrow_mut();

        let node_cmds = self.map_cmds_to_nodes(cmds)?;
        for nc in &node_cmds {
            self.get_connection_by_addr(&mut connections, &nc.addr)?
                .send_packed_command(&nc.pipe)?;
        }
        Ok(node_cmds)
    }
// Build up a pipeline per node, then send it
Build up a pipeline per node, then send it
Build up a pipeline per node then send it
fn send_all_commands(&self, cmds: &[Cmd]) -> RedisResult<Vec<NodeCmd>> {
        let mut connections = self.connections.borrow_mut();
        let node_cmds = self.map_cmds_to_nodes(cmds)?;
        for nc in &node_cmds {
            self.get_connection_by_addr(&mut connections, &nc.addr)?
                .send_packed_command(&nc.pipe)?;
        }
        Ok(node_cmds)
    }
fn send_all_commands ( & self , cmds : & [ Cmd ] ) -> RedisResult < Vec < NodeCmd > > { let mut connections = self . connections . borrow_mut ( ) ; let node_cmds = self . map_cmds_to_nodes ( cmds ) ? ; for nc in & node_cmds { self . get_connection_by_addr ( & mut connections , & nc . addr ) ? . send_packed_command ( & nc . pipe ) ? ; } Ok ( node_cmds ) }
Build up a pipeline per node, then send it
Build up a pipeline per node then send it
&self
cmds
&[Cmd]
&self
cmds
&[Cmd]