Struct gmt_dos_clients_transceiver::Transceiver

pub struct Transceiver<U: UniqueIdentifier, F = Unset, S = Off> {
    pub rx: Option<Receiver<Data<U>>>,
    /* private fields */
}

Transmitter and receiver of gmt_dos-actors Data

Fields

rx: Option<Receiver<Data<U>>>

Implementations

impl<U: UniqueIdentifier> Transceiver<U>

pub fn receiver<S: Into<String>, C: Into<String>>( server_address: S, client_address: C ) -> Result<Transceiver<U, Receiver>>

Transceiver receiver functionality

A receiver is build from both the transmitter and the receiver internet socket addresses

Examples

let tx_address = "127.0.0.1:5001";
let rx_address = "127.0.0.1:500";
let tx = Transceiver::<IO>::receiver(tx_address,rx_address).unwrap();

pub fn receiver_builder<S: Into<String>, C: Into<String>>( server_address: S, client_address: C ) -> ReceiverBuilder<U>

impl<U: UniqueIdentifier> Transceiver<U, Receiver>

pub fn spawn<V: UniqueIdentifier, A: Into<String>>( &self, server_address: A ) -> Result<Transceiver<V, Receiver>>

Spawn a new Transceiver receiver

clone the receiver endpoint that will server_address to connect to

impl<U: UniqueIdentifier + 'static> Transceiver<U, Receiver>

pub fn run(self, monitor: &mut Monitor) -> Transceiver<U, Receiver, On>

where <U as UniqueIdentifier>::DataType: Send + Sync + for<'a> Deserialize<'a>,

Receive data from the transmitter

Communication with the transmitter happens in a separate thread. The receiver will timed-out after 10s if no connection can be established with the transmitter

impl<U: UniqueIdentifier> Transceiver<U>

pub fn transmitter<S: Into<String>>( address: S ) -> Result<Transceiver<U, Transmitter>>

Transceiver transmitter functionality

A transmitter is build from its internet socket address

Examples

let address = "127.0.0.1:5001";
let tx = Transceiver::<IO>::transmitter(address).unwrap();

pub fn transmitter_builder<S: Into<String>>(address: S) -> TransmitterBuilder<U>

impl<U: UniqueIdentifier + 'static> Transceiver<U, Transmitter>

pub fn run(self, monitor: &mut Monitor) -> Transceiver<U, Transmitter, On>

where <U as UniqueIdentifier>::DataType: Send + Sync + Serialize,

Send data to the receiver

Communication with the receiver happens in a separate thread. The transmitter will hold until the receiver calls in.

impl<U: UniqueIdentifier, F> Transceiver<U, F>

pub fn new<S: Into<String>>( crypto: Crypto, server_address: S, endpoint: Endpoint, inner_channel: InnerChannel ) -> Self

impl<U: UniqueIdentifier, F, S> Transceiver<U, F, S>

pub fn take_channel_receiver(&mut self) -> Option<Receiver<Data<U>>>

Trait Implementations

impl<U: UniqueIdentifier, F, S> Debug for Transceiver<U, F, S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<U: UniqueIdentifier> From<&Transceiver<U, Receiver>> for CompactRecvr

fn from(value: &Transceiver<U, Receiver>) -> Self

Converts to this type from the input type.

impl<U: UniqueIdentifier> Read<U> for Transceiver<U, Transmitter, On>

fn read(&mut self, data: Data<U>)

Read data from an input

impl<U: UniqueIdentifier, F: RxOrTx + Send + Sync> Update for Transceiver<U, F, On>

fn update(&mut self)

impl<U: UniqueIdentifier> Write<U> for Transceiver<U, Receiver, On>

fn write(&mut self) -> Option<Data<U>>