def read(self, reader):

        assert not self._reader, "There's already a reader installed."
        self._reader = reader
        self._add_io_state(self.io.READ)
        return self
Add a reader to this stream.  There can only be one reader
dataset/ETHPy150Open HenryHu/pybbs/xmpp/readstream.py/ReadStream.read