Struct scuttlebutt::SyncChannel

pub struct SyncChannel<R, W> { /* fields omitted */ }

A channel that implements AbstractChannel as well as Send and Sync.

Methods

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

pub fn new(reader: R, writer: W) -> Self

Make a new Channel from a reader and a writer.

pub fn reader(self) -> Arc<Mutex<R>>

Return a reader object wrapped in Arc<Mutex<R>>.

pub fn writer(self) -> Arc<Mutex<W>>

Return a writer object wrapped in Arc<Mutex<W>>.

Trait Implementations

impl<R: Read, W: Write> AbstractChannel for SyncChannel<R, W>

fn write_bytes(&mut self, bytes: &[u8]) -> Result<()>

Write a slice of u8s to the channel.

fn read_bytes(&mut self, bytes: &mut [u8]) -> Result<()>

Read a slice of u8s from the channel.

fn flush(&mut self) -> Result<()>

Flush the channel.

fn clone(&self) -> Self

Clone the channel.

fn write_bool(&mut self, b: bool) -> Result<()>

Write a bool to the channel.

fn read_bool(&mut self) -> Result<bool>

Read a bool from the channel.

fn write_usize(&mut self, s: usize) -> Result<()>

Write a usize to the channel.

fn read_usize(&mut self) -> Result<usize>

Read a usize from the channel.

fn write_block(&mut self, b: &Block) -> Result<()>

Write a Block to the channel.

fn read_block(&mut self) -> Result<Block>

Read a Block from the channel.

fn write_block512(&mut self, b: &Block512) -> Result<()>

Write a Block512 to the channel.

fn read_block512(&mut self) -> Result<Block512>

Read a Block512 from the channel.

fn write_pt(&mut self, pt: &RistrettoPoint) -> Result<()>

Write a RistrettoPoint to the channel.

fn read_pt(&mut self) -> Result<RistrettoPoint>

Read a RistrettoPoint from the channel.