Lines Matching refs:_in
41 _in, _out = Queue(), Queue()42 address.put((_out, _in))43 return Connection(_in, _out)53 def __init__(self, _in, _out):55 self._in = _in57 self.recv = self.recv_bytes = _in.get60 if self._in.qsize() > 0:64 with self._in.not_empty:65 self._in.not_empty.wait(timeout)66 return self._in.qsize() > 0