Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(6)  |  Call(6)  |  Derive(0)  |  Import(0)

src/p/y/PyRQ-0.4.1/test/RRQReader/TestQueueBlocking.py   PyRQ(Download)
        iface = PyRQIface(namespace=namespace, quiet=self.quiet, ref="testDelayedGetThenClosed")
        try:
            data = iface.get(block=True, timeout=None)
        except (ClosedError, Finished):
            assert True
        iface = PyRQIface(namespace=namespace, quiet=self.quiet, ref="testDelayedGetWithTimeoutThenClosed")
        try:
            iface.get(block=True, timeout=10)
        except (ClosedError, Empty):
            assert True

src/p/y/PyRQ-0.4.1/test/RRQReader/TestRRQReader.py   PyRQ(Download)
            while self.timerTerminate==0:
                try:
                    data = iface.get(block=True, timeout=min(1, min(1, getTimeout)))
                except Empty, data:
                    continue
    def testNonBlockingGet(self):
        self.namespace = self._createInterface()
        iface = PyRQIface(ref="testNonBlockingGet", namespace=self.namespace, quiet=self.quiet, loggingModule=testLoggingModule)
        try:
            _data = iface.get(block=False, timeout=None)
        iface = PyRQIface(ref="testPostCloseDifferentIface.1", namespace=self.namespace, quiet=self.quiet, loggingModule=testLoggingModule)
        try:
            iface.get(block=block, timeout=timeout)
        except ClosedError, _e:
            assert True
                rtn = False
                try:
                    data = iface.get(timeout=getTimeout)
                except Empty, data:
                    rtn = True