Struct scuttlebutt::channel::SyncChannel

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

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

Implementations

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 read_vec(&mut self, nbytes: usize) -> Result<Vec<u8>>

Read nbytes from the channel, and return it as a Vec.

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_u8(&mut self, s: u8) -> Result<()>

Write a u8 to the channel.

fn read_u8(&mut self) -> Result<u8>

Read a u8 from the channel.

fn write_u16(&mut self, s: u16) -> Result<()>

Write a u16 to the channel.

fn read_u16(&mut self) -> Result<u16>

Read a u16 from the channel.

fn write_u32(&mut self, s: u32) -> Result<()>

Write a u32 to the channel.

fn read_u32(&mut self) -> Result<u32>

Read a u32 from the channel.

fn write_u64(&mut self, s: u64) -> Result<()>

Write a u64 to the channel.

fn read_u64(&mut self) -> Result<u64>

Read a u64 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 read_blocks(&mut self, n: usize) -> Result<Vec<Block>>

Read n Blocks 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.

fn read_serializable<E: CanonicalSerialize>(&mut self) -> Result<E>

Read a CanonicalSerialize object from the channel.

fn write_serializable<E: CanonicalSerialize>(&mut self, x: &E) -> Result<()>

Write a CanonicalSerialize object to the channel.