Struct tlspuffin::tcp::TcpServerPut

pub struct TcpServerPut {
    stream: Option<(TcpStream, TcpListener)>,
    stream_receiver: Receiver<(TcpStream, TcpListener)>,
    agent_descriptor: AgentDescriptor,
    process: Option<TLSProcess>,
}

Fields

stream: Option<(TcpStream, TcpListener)>

stream_receiver: Receiver<(TcpStream, TcpListener)>

agent_descriptor: AgentDescriptor

process: Option<TLSProcess>

Implementations

impl TcpServerPut

fn new( agent_descriptor: &AgentDescriptor, options: &PutOptions, ) -> Result<Self, Error>

pub fn set_process(&mut self, process: TLSProcess)

pub fn receive_stream(&mut self)

Trait Implementations

impl Put<TLSProtocolBehavior> for TcpServerPut

fn progress(&mut self) -> Result<(), Error>

Process incoming buffer, internal progress, can fill in the output buffer

fn reset(&mut self, _new_name: AgentName) -> Result<(), Error>

In-place reset of the state

fn descriptor(&self) -> &AgentDescriptor

fn describe_state(&self) -> &str

Returns a textual representation of the state in which self is

fn is_state_successful(&self) -> bool

Checks whether the Put is in a good state

fn shutdown(&mut self) -> String

Shut down the PUT by consuming it and returning a string that summarizes the execution.

fn version() -> String

where Self: Sized,

Returns a textual representation of the version of the PUT used by self

impl Stream<TLSProtocolBehavior> for TcpServerPut

fn add_to_inbound(&mut self, opaque_flight: &OpaqueMessageFlight)

fn take_message_from_outbound( &mut self, ) -> Result<Option<OpaqueMessageFlight>, Error>

Takes a single TLS message from the outbound channel

impl TcpPut for TcpServerPut

fn write_to_stream(&mut self, buf: &[u8]) -> Result<()>

fn read_to_flight(&mut self) -> Result<Option<OpaqueMessageFlight>, Error>