Lines Matching refs:cid
221 def run_action(cid, action, end, state, *, hideclosed=True):
231 result = _run_action(cid, action, end, state)
242 def _run_action(cid, action, end, state):
245 interpreters.channel_send(cid, b'spam')
250 interpreters.channel_recv(cid)
256 interpreters.channel_recv(cid)
264 interpreters.channel_close(cid, **kwargs)
272 interpreters.channel_close(cid, **kwargs)
289 for cid in interpreters.channel_list_all():
291 interpreters.channel_destroy(cid)
360 self.cid = interpreters.channel_create()
363 interpreters.channel_destroy(self.cid)
369 interpreters.channel_send(self.cid, obj)
370 got = interpreters.channel_recv(self.cid)
380 interpreters.channel_send(self.cid, obj)
381 got = interpreters.channel_recv(self.cid)
390 self.cid,
413 interpreters.channel_send(self.cid, i)
1077 cid = interpreters._channel_id(10, force=True)
1079 self.assertEqual(int(cid), 10)
1080 self.assertEqual(cid.end, 'both')
1083 cid = interpreters._channel_id(10, send=True, force=True)
1084 self.assertEqual(cid.end, 'send')
1086 cid = interpreters._channel_id(10, send=True, recv=False, force=True)
1087 self.assertEqual(cid.end, 'send')
1089 cid = interpreters._channel_id(10, recv=True, force=True)
1090 self.assertEqual(cid.end, 'recv')
1092 cid = interpreters._channel_id(10, recv=True, send=False, force=True)
1093 self.assertEqual(cid.end, 'recv')
1095 cid = interpreters._channel_id(10, send=True, recv=True, force=True)
1096 self.assertEqual(cid.end, 'both')
1103 cid = interpreters._channel_id(Int(), force=True)
1104 self.assertEqual(int(cid), 10)
1119 cid = interpreters.channel_create()
1121 interpreters._channel_id(int(cid) + 1) # unforced
1124 cid = interpreters._channel_id(10, force=True)
1125 self.assertEqual(str(cid), '10')
1128 cid = interpreters._channel_id(10, force=True)
1129 self.assertEqual(repr(cid), 'ChannelID(10)')
1131 cid = interpreters._channel_id(10, send=True, force=True)
1132 self.assertEqual(repr(cid), 'ChannelID(10, send=True)')
1134 cid = interpreters._channel_id(10, recv=True, force=True)
1135 self.assertEqual(repr(cid), 'ChannelID(10, recv=True)')
1137 cid = interpreters._channel_id(10, send=True, recv=True, force=True)
1138 self.assertEqual(repr(cid), 'ChannelID(10)')
1166 cid = interpreters.channel_create()
1167 self.assertIsInstance(cid, interpreters.ChannelID)
1184 cid = _interpreters.channel_create()
1185 print(cid)
1192 cid = _interpreters.channel_create()
1193 print(cid)
1202 cid = interpreters.channel_create()
1203 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1204 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1211 cid = interpreters.channel_create()
1212 interpreters.channel_send(cid, "send")
1214 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1215 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1222 obj = _interpreters.channel_recv({cid})
1225 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1226 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1236 cid = interpreters.channel_create()
1238 interpreters.channel_send(cid, "send")
1241 _interpreters.channel_send({cid}, "send")
1245 obj = _interpreters.channel_recv({cid})
1249 obj = _interpreters.channel_recv({cid})
1251 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1252 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1260 cid = interpreters.channel_create()
1261 interpreters.channel_send(cid, "send")
1264 obj = _interpreters.channel_recv({cid})
1267 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1268 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1274 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1275 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1286 cid = interpreters.channel_create()
1287 interpreters.channel_send(cid, "data")
1290 obj = _interpreters.channel_recv({cid})
1292 interpreters.channel_send(cid, "data")
1295 obj = _interpreters.channel_recv({cid})
1298 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1299 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1304 interpreters.channel_release(cid, send=True)
1306 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1307 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1314 _interpreters.channel_release({cid})
1317 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1318 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1326 cid = interpreters.channel_create()
1328 interpreters.channel_send(cid, "send")
1331 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1332 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1337 interpreters.channel_close(cid, force=True)
1340 interpreters.channel_list_interpreters(cid, send=True)
1342 interpreters.channel_list_interpreters(cid, send=False)
1348 cid = interpreters.channel_create()
1350 interpreters.channel_send(cid, "send")
1353 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1354 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1359 interpreters.channel_close(cid, send=True)
1362 interpreters.channel_list_interpreters(cid, send=True)
1364 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1370 _interpreters.channel_close({cid}, force=True)
1374 interpreters.channel_list_interpreters(cid, send=True)
1376 interpreters.channel_list_interpreters(cid, send=False)
1381 cid = interpreters.channel_create()
1383 interpreters.channel_send(cid, orig)
1384 obj = interpreters.channel_recv(cid)
1393 cid = _interpreters.channel_create()
1395 _interpreters.channel_send(cid, orig)
1396 obj = _interpreters.channel_recv(cid)
1402 cid = interpreters.channel_create()
1406 _interpreters.channel_send({cid}, b'spam')
1408 obj = interpreters.channel_recv(cid)
1413 cid = interpreters.channel_create()
1418 obj = interpreters.channel_recv(cid)
1422 interpreters.channel_send(cid, obj)
1426 interpreters.channel_send(cid, b'spam')
1428 obj = interpreters.channel_recv(cid)
1433 cid = interpreters.channel_create()
1444 obj = _interpreters.channel_recv({cid})
1449 _interpreters.channel_send({cid}, b'eggs')
1454 interpreters.channel_send(cid, b'spam')
1456 obj = interpreters.channel_recv(cid)
1469 cid = interpreters.channel_create()
1471 interpreters.channel_recv(cid)
1475 cid = interpreters.channel_create()
1476 obj1 = interpreters.channel_recv(cid, default)
1477 interpreters.channel_send(cid, None)
1478 interpreters.channel_send(cid, 1)
1479 interpreters.channel_send(cid, b'spam')
1480 interpreters.channel_send(cid, b'eggs')
1481 obj2 = interpreters.channel_recv(cid, default)
1482 obj3 = interpreters.channel_recv(cid, default)
1483 obj4 = interpreters.channel_recv(cid)
1484 obj5 = interpreters.channel_recv(cid, default)
1485 obj6 = interpreters.channel_recv(cid, default)
1495 cid = interpreters.channel_create()
1500 print(cid.end)
1501 _interpreters.channel_send(cid, b'spam')
1503 dict(cid=cid.send))
1504 obj = interpreters.channel_recv(cid)
1514 cid = interpreters.channel_create()
1515 cid = interpreters._channel_id(cid, _resolve=True)
1523 dict(chan=cid.send))
1524 obj = interpreters.channel_recv(cid)
1532 cid = interpreters.channel_create()
1533 interpreters.channel_send(cid, b'spam')
1534 interpreters.channel_recv(cid)
1535 interpreters.channel_close(cid)
1538 interpreters.channel_send(cid, b'eggs')
1540 interpreters.channel_recv(cid)
1543 cid = interpreters.channel_create()
1548 _interpreters.channel_send({cid}, b'spam')
1552 _interpreters.channel_recv({cid})
1554 interpreters.channel_close(cid)
1557 _interpreters.channel_send({cid}, b'spam')
1562 _interpreters.channel_send({cid}, b'spam')
1567 cid = interpreters.channel_create()
1568 interpreters.channel_send(cid, b'spam')
1569 interpreters.channel_recv(cid)
1570 interpreters.channel_close(cid)
1573 interpreters.channel_close(cid)
1584 cid = interpreters.channel_create()
1585 interpreters.channel_send(cid, b'spam')
1586 interpreters.channel_recv(cid)
1587 interpreters.channel_close(cid, send=send, recv=recv)
1590 interpreters.channel_send(cid, b'eggs')
1592 interpreters.channel_recv(cid)
1595 cid = interpreters.channel_create()
1596 interpreters.channel_send(cid, b'spam')
1597 interpreters.channel_send(cid, b'ham')
1600 interpreters.channel_close(cid)
1601 interpreters.channel_recv(cid)
1602 interpreters.channel_send(cid, b'eggs')
1605 cid = interpreters.channel_create()
1606 interpreters.channel_send(cid, b'spam')
1607 interpreters.channel_send(cid, b'ham')
1610 interpreters.channel_close(cid, recv=True)
1611 interpreters.channel_recv(cid)
1612 interpreters.channel_send(cid, b'eggs')
1613 interpreters.channel_recv(cid)
1614 interpreters.channel_recv(cid)
1615 interpreters.channel_close(cid, recv=True)
1618 cid = interpreters.channel_create()
1619 interpreters.channel_send(cid, b'spam')
1620 interpreters.channel_send(cid, b'ham')
1621 interpreters.channel_close(cid, send=True)
1624 interpreters.channel_send(cid, b'eggs')
1625 interpreters.channel_recv(cid)
1626 interpreters.channel_recv(cid)
1628 interpreters.channel_recv(cid)
1631 cid = interpreters.channel_create()
1632 interpreters.channel_send(cid, b'spam')
1633 interpreters.channel_send(cid, b'ham')
1636 interpreters.channel_close(cid, recv=True, send=True)
1637 interpreters.channel_recv(cid)
1638 interpreters.channel_send(cid, b'eggs')
1639 interpreters.channel_recv(cid)
1640 interpreters.channel_recv(cid)
1641 interpreters.channel_close(cid, recv=True)
1644 cid = interpreters.channel_create()
1645 interpreters.channel_send(cid, b'spam')
1646 interpreters.channel_send(cid, b'ham')
1647 interpreters.channel_close(cid, recv=True, force=True)
1650 interpreters.channel_send(cid, b'eggs')
1652 interpreters.channel_recv(cid)
1655 cid = interpreters.channel_create()
1656 interpreters.channel_send(cid, b'spam')
1657 interpreters.channel_send(cid, b'ham')
1658 interpreters.channel_close(cid, send=True, force=True)
1661 interpreters.channel_send(cid, b'eggs')
1663 interpreters.channel_recv(cid)
1666 cid = interpreters.channel_create()
1667 interpreters.channel_send(cid, b'spam')
1668 interpreters.channel_send(cid, b'ham')
1669 interpreters.channel_close(cid, send=True, recv=True, force=True)
1672 interpreters.channel_send(cid, b'eggs')
1674 interpreters.channel_recv(cid)
1677 cid = interpreters.channel_create()
1678 interpreters.channel_close(cid)
1681 interpreters.channel_send(cid, b'spam')
1683 interpreters.channel_recv(cid)
1686 cid = interpreters.channel_create()
1687 interpreters.channel_send(cid, b'spam')
1691 _interpreters.channel_close({cid}, force=True)
1694 interpreters.channel_recv(cid)
1696 interpreters.channel_close(cid)
1699 cid = interpreters.channel_create()
1700 interpreters.channel_send(cid, b'spam')
1701 interpreters.channel_send(cid, b'spam')
1702 interpreters.channel_send(cid, b'spam')
1703 interpreters.channel_recv(cid)
1704 interpreters.channel_close(cid, force=True)
1707 interpreters.channel_send(cid, b'eggs')
1709 interpreters.channel_recv(cid)
1712 cid = interpreters.channel_create()
1717 interpreters.channel_close(cid)
1720 interpreters.channel_list_interpreters(cid, send=True)
1724 cid = interpreters.channel_create()
1726 interpreters.channel_list_interpreters(cid)
1773 cid = interpreters.channel_create()
1774 interpreters.channel_send(cid, b'spam')
1775 interpreters.channel_recv(cid)
1776 interpreters.channel_release(cid, send=True, recv=True)
1779 interpreters.channel_send(cid, b'eggs')
1781 interpreters.channel_recv(cid)
1784 cid = interpreters.channel_create()
1789 _interpreters.channel_send({cid}, b'spam')
1793 obj = _interpreters.channel_recv({cid})
1794 _interpreters.channel_release({cid})
1798 _interpreters.channel_release({cid})
1804 cid = interpreters.channel_create()
1805 interpreters.channel_send(cid, b'spam')
1806 interpreters.channel_recv(cid)
1807 interpreters.channel_release(cid)
1810 interpreters.channel_send(cid, b'eggs')
1812 interpreters.channel_recv(cid)
1815 cid = interpreters.channel_create()
1816 interpreters.channel_send(cid, b'spam')
1817 interpreters.channel_recv(cid)
1818 interpreters.channel_release(cid, send=True, recv=True)
1821 interpreters.channel_release(cid, send=True, recv=True)
1824 cid = interpreters.channel_create()
1825 interpreters.channel_send(cid, b'spam')
1826 interpreters.channel_send(cid, b'ham')
1827 interpreters.channel_release(cid, send=True, recv=True)
1830 interpreters.channel_recv(cid)
1833 cid = interpreters.channel_create()
1834 interpreters.channel_release(cid)
1837 interpreters.channel_send(cid, b'spam')
1839 interpreters.channel_recv(cid)
1842 cid = interpreters.channel_create()
1843 interpreters.channel_send(cid, b'spam')
1847 _interpreters.channel_release({cid})
1849 obj = interpreters.channel_recv(cid)
1850 interpreters.channel_release(cid)
1853 interpreters.channel_send(cid, b'eggs')
1858 cid = interpreters.channel_create()
1862 obj = _interpreters.channel_send({cid}, b'spam')
1863 _interpreters.channel_release({cid})
1867 interpreters.channel_recv(cid)
1871 cid = interpreters.channel_create()
1872 interpreters.channel_send(cid, None)
1873 interpreters.channel_recv(cid)
1874 interpreters.channel_send(cid, b'spam')
1875 interpreters.channel_release(cid, send=True)
1876 obj = interpreters.channel_recv(cid)
1881 cid = interpreters.channel_create()
1882 interpreters.channel_send(cid, b'spam')
1883 interpreters.channel_send(cid, b'spam')
1884 interpreters.channel_send(cid, b'spam')
1885 interpreters.channel_recv(cid)
1886 interpreters.channel_release(cid, send=True, recv=True)
1889 interpreters.channel_send(cid, b'eggs')
1891 interpreters.channel_recv(cid)
1927 def cid(self):
1966 cid = _xxsubinterpreters.channel_create()
1969 _xxsubinterpreters.channel_send({ch}, int(cid))
2001 cid
2003 cid = interpreters._channel_id({self.cid})
2182 fix.cid,
2193 {fix.cid},
2233 interpreters.channel_recv(fix.cid)
2235 interpreters.channel_send(fix.cid, b'spam')
2237 interpreters.channel_close(fix.cid)
2239 interpreters.channel_close(fix.cid, force=True)
2243 interpreters.channel_recv(cid)
2247 interpreters.channel_send(cid, b'spam')
2251 interpreters.channel_close(cid)
2255 interpreters.channel_close(cid, force=True)
2262 interpreters.channel_recv(fix.cid)