Lines Matching refs:_in

58     _in, _out = Queue(), Queue()
59     address.put((_out, _in))
60     return Connection(_in, _out)
70     def __init__(self, _in, _out):  argument
72         self._in = _in
74         self.recv = self.recv_bytes = _in.get
77         if self._in.qsize() > 0:
81         self._in.not_empty.acquire()
82         self._in.not_empty.wait(timeout)
83         self._in.not_empty.release()
84         return self._in.qsize() > 0