protocol.abstract.stream Module

Abstract stream classes

class wpull.protocol.abstract.stream.DataEventDispatcher[source]

Bases: object

add_read_listener(callback: typing.Callable)[source]
add_write_listener(callback: typing.Callable)[source]
notify_read(data: bytes)[source]
notify_write(data: bytes)[source]
remove_read_listener(callback: typing.Callable)[source]
remove_write_listener(callback: typing.Callable)[source]
wpull.protocol.abstract.stream.close_stream_on_error(func)[source]

Decorator to close stream on error.