iofree package

iofree is an easy-to-use and powerful library to help you implement network protocols and binary parsers.

class iofree.Parser(gen: Generator)

Bases: object

finished() → bool

get_result()

raises NoResult exception if no result has been set

has_more_data() → bool

indicate whether input has some bytes left

property has_result

parse(data: bytes, *, strict: bool = True) → Any

parse bytes

read(nbytes: int = 0) → bytes

read at most nbytes

readall() → bytes

retrieve data from input back

respond(*, data: bytes = b'', close: bool = False, exc: Optional[Exception] = None, result: Any = <object object>) → None

produce some event data to interact with a stream: data: bytes to send to the peer close: whether the socket should be closed exc: raise an exception to break the loop result: result to return

run(sock: _socket.socket)

reference implementation of how to deal with socket

send(data: bytes = b'') → None

send data for parsing

set_result(result)

write(data: bytes) → None

class iofree.State

Bases: enum.IntEnum

An enumeration.

class iofree.Traps

Bases: enum.IntEnum

An enumeration.

iofree.get_parser() → iofree.Parser

get current parser object

iofree.parser(generator_func: Generator) → Generator

decorator function to wrap a generator

iofree.peek(nbytes: int = 1, *, from_=None) → bytes

peek many bytes without taking them away from buffer

iofree.read(nbytes: int = 0, *, from_=None) → bytes

if nbytes = 0, read as many as possible, empty bytes is valid; if nbytes > 0, read exactly nbytes

iofree.read_int(nbytes: int, byteorder: str = 'big', *, signed=False, from_=None) → int

read some bytes as integer

iofree.read_more(nbytes: int = 1, *, from_=None) → bytes

read at least nbytes

iofree.read_raw_struct(struct_obj: Struct, *, from_=None) → tuple

read raw struct formatted data

iofree.read_struct(fmt: str, *, from_=None) → tuple

read specific formatted data

iofree.read_until(data: bytes, *, return_tail: bool = True, from_=None) → bytes

read until some bytes appear

iofree.wait() → None

wait for next send or get_result event

iofree.write(data: bytes) → None

write some bytes to the output buffer

Submodules

• iofree.exceptions module
• iofree.schema module