update_data¶

service¶

class UpdateDataService¶

Bases: Service

clear(msg: ClearDataMessage)¶

get(msg: GetDataMessage)¶

handle_message(_)¶
handle_message(msg: GetDataMessage)
handle_message(msg: PutDataMessage)
handle_message(msg: ClearDataMessage)

handle_request(req: Tuple[str, Message])¶

classmethod install(obj: Extensible)¶

logger: Logger¶

put(msg: PutDataMessage)¶

run()¶

setup(*, stream: BaseStream, logger: Logger, **_)¶

socket: MessageRouterSocket¶

stream: BaseStream[Tuple[str, Message]]¶