Struct ether_dream_dac_emulator::stream::Stream

pub struct Stream { /* fields omitted */ }

A stream of communication between a DAC and a user.

The stream expects to receive Commands and responseds with DacResponses.

All communication occurs over a single TCP stream.

Implementations

impl Stream

pub fn new(dac: Addressed, stream: Async<TcpStream>) -> Result<Self>

Initialise a new Stream.

Internally this allocates a buffer of bytes whose size is the size of the largest possible Data command that may be received based on the DAC's buffer capacity.

Assumes TCP_NODELAY is already enabled on the given TCP socket in order to adhere to the low-latency, realtime requirements.

This function also spawns a thread used for processing output.

pub fn dac(&self) -> Addressed

Produce the current state of the DAC.

pub async fn next_points<'_>(
    &'_ mut self
) -> Result<Result<Vec<DacPoint>, Underflowed>>

Handle TCP messages received on the given stream by attempting to interpret them as commands.

Once processed, each command will be responded to.

This runs forever until either an error occurs or the TCP stream is shutdown.

Returns the io::Error that caused the loop to end.