This module contains the stub connection.
@contextmanager lock_file(file_descriptor: IO[bytes])
Lock file in context manager.
file_descriptor: file descriptio of file to lock.
write_envelope(envelope: Envelope, file_pointer: IO[bytes]) -> None
Write envelope to file.
write_with_lock(file_pointer: IO[bytes], data: Union[bytes]) -> None
Write bytes to file protected with file lock.
Initialize a stub connection.
| async read_envelopes() -> None
Read envelopes from inptut file, decode and put into in_queue.
| async receive(*args, **kwargs) -> Optional["Envelope"]
Receive an envelope.
| async connect() -> None
Set up the connection.
| async disconnect() -> None
Disconnect from the channel.
In this type of connection there's no channel to disconnect.
| async send(envelope: Envelope) -> None