Struct TCPTransport 

pub struct TCPTransport<C: MakeConnection> { /* private fields */ }

Implements connecting to Twitch chat via secured or unsecured plain IRC connection.

Trait Implementations

impl<C: MakeConnection> Debug for TCPTransport<C>

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

Formats the value using the given formatter.

impl<C: MakeConnection> Transport for TCPTransport<C>

type ConnectError = TCPTransportConnectError

Error type for creating a new connection via new()

type IncomingError = Error

Error type returned from the Self::Incoming stream type.

type OutgoingError = Error

Error type returned from the Self::Outgoing sink type.

type Incoming = Box<dyn FusedStream<Item = Result<IRCMessage, Either<Error, IRCParseError>>> + Send + Unpin + Sync>

Type of stream of incoming messages.

type Outgoing = Box<dyn Sink<IRCMessage, Error = <TCPTransport<C> as Transport>::OutgoingError> + Send + Unpin + Sync>

Type of outgoing messages sink.

fn new<'async_trait>() -> Pin<Box<dyn Future<Output = Result<TCPTransport<C>, TCPTransportConnectError>> + Send + 'async_trait>>

Try to create and connect a new Transport of this type. Returns Ok(Self) after the connection was established successfully.

fn split(self) -> (Self::Incoming, Self::Outgoing)

Split this transport into its incoming and outgoing halves (streams).