Struct scuttlebutt::channel::TrackChannel

pub struct TrackChannel<C>(/* private fields */);

A channel wrapping another channel for tracking the number of bits read/written.

Implementations

impl<C: AbstractChannel> TrackChannel<C>

pub fn new(channel: C) -> Self

Make a new TrackChannel from a reader and a writer.

pub fn clear(&mut self)

Clear the number of bits read/written.

pub fn kilobits_written(&self) -> f64

Return the number of kilobits written to the channel.

pub fn kilobits_read(&self) -> f64

Return the number of kilobits read from the channel.

pub fn total_kilobits(&self) -> f64

Return the total amount of communication on the channel.

pub fn kilobytes_written(&self) -> f64

Return the number of kilobytes written to the channel.

pub fn kilobytes_read(&self) -> f64

Return the number of kilobytes read from the channel.

pub fn total_kilobytes(&self) -> f64

Return the total amount of communication on the channel as kilobytes.

Trait Implementations

impl<C: AbstractChannel> AbstractChannel for TrackChannel<C>

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.