Struct TcpServerMocker

pub struct TcpServerMocker { /* private fields */ }

A TCP server mocker

Can be used to mock a TCP server if the application you want to test uses TCP sockets to connect to a server.

Only 1 client can be connected to the mocked server. When the connection is closed, the mocked server will stop.

Implementations

impl TcpServerMocker

pub fn new() -> Result<Self, ServerMockerError>

Create a new instance of the TCP server mocker on a random free port. The port can be retrieved with the ServerMocker::port method.

pub fn new_with_port(port: u16) -> Result<Self, ServerMockerError>

Create a new instance of the TCP server mocker on the given port. If the port is already in use, the method will return an error.

Trait Implementations

impl ServerMocker for TcpServerMocker

TcpServerMocker implementation

Example

use std::io::Write;
use std::net::TcpStream;
use socket_server_mocker::server_mocker::ServerMocker;
use socket_server_mocker::server_mocker_instruction::Instruction;
use socket_server_mocker::server_mocker_instruction::Instruction::{ReceiveMessage, StopExchange};
use socket_server_mocker::tcp_server_mocker::TcpServerMocker;

let tcp_server_mocker = TcpServerMocker::new_with_port(1234).unwrap();
let mut client = TcpStream::connect("127.0.0.1:1234").unwrap();

tcp_server_mocker.add_mock_instructions(vec![
    ReceiveMessage,
    StopExchange,
]).unwrap();
client.write_all(&[1, 2, 3]).unwrap();

let mock_server_received_message = tcp_server_mocker.pop_received_message();
assert_eq!(Some(vec![1, 2, 3]), mock_server_received_message);
assert!(tcp_server_mocker.pop_server_error().is_none());
assert!(tcp_server_mocker.pop_server_error().is_none());

fn socket_address(&self) -> SocketAddr

Returns the socket address on which the mock server is listening

fn add_mock_instructions( &self, instructions: Vec<Instruction>, ) -> Result<(), ServerMockerError>

Adds a slice of instructions to the server mocker

fn pop_received_message(&self) -> Option<BinaryMessage>

Return first message received by the mock server on the messages queue

fn pop_server_error(&self) -> Option<ServerMockerError>

Return first error received by the mock server on the errors queue

const DEFAULT_NET_TIMEOUT_MS: u64 = 100u64

Default timeout in milliseconds for the server to wait for a message from the client.

const DEFAULT_THREAD_RECEIVER_TIMEOUT_MS: u64 = 100u64

Timeout if no more instruction is available and Instruction::StopExchange hasn’t been sent

fn port(&self) -> u16

Returns the port on which the mock server is listening