Files
py-libp2p/libp2p/protocol_muxer/multiselect_communicator_interface.py
2024-02-19 16:05:58 -07:00

25 lines
548 B
Python

from abc import (
ABC,
abstractmethod,
)
class IMultiselectCommunicator(ABC):
"""
Communicator helper class that ensures both the client and multistream
module will follow the same multistream protocol, which is necessary for
them to work.
"""
@abstractmethod
async def write(self, msg_str: str) -> None:
"""
Write message to stream.
:param msg_str: message to write
"""
@abstractmethod
async def read(self) -> str:
"""Reads message from stream until EOF."""