本文整理汇总了Python中asyncio.isfuture方法的典型用法代码示例。如果您正苦于以下问题：Python asyncio.isfuture方法的具体用法？Python asyncio.isfuture怎么用？Python asyncio.isfuture使用的例子？那么恭喜您, 这里精选的方法代码示例或许可以为您提供帮助。您也可以进一步了解该方法所在模块asyncio的用法示例。
在下文中一共展示了asyncio.isfuture方法的10个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: test_isfuture
点赞 6
# 需要导入模块: import asyncio [as 别名]
# 或者: from asyncio import isfuture [as 别名]
def test_isfuture(self):
class MyFuture:
_asyncio_future_blocking = None
def __init__(self):
self._asyncio_future_blocking = False
self.assertFalse(asyncio.isfuture(MyFuture))
self.assertTrue(asyncio.isfuture(MyFuture()))
self.assertFalse(asyncio.isfuture(1))
self.assertFalse(asyncio.isfuture(asyncio.Future))
# As `isinstance(Mock(), Future)` returns `False`
self.assertFalse(asyncio.isfuture(mock.Mock()))
# As `isinstance(Mock(Future), Future)` returns `True`
self.assertTrue(asyncio.isfuture(mock.Mock(asyncio.Future)))
f = asyncio.Future(loop=self.loop)
self.assertTrue(asyncio.isfuture(f))
f.cancel()
开发者ID:ShikyoKira，项目名称:Project-New-Reign---Nemesis-Main，代码行数:24，
示例2: test_isfuture
点赞 6
# 需要导入模块: import asyncio [as 别名]
# 或者: from asyncio import isfuture [as 别名]
def test_isfuture(self):
class MyFuture:
_asyncio_future_blocking = None
def __init__(self):
self._asyncio_future_blocking = False
self.assertFalse(asyncio.isfuture(MyFuture))
self.assertTrue(asyncio.isfuture(MyFuture()))
self.assertFalse(asyncio.isfuture(1))
# As `isinstance(Mock(), Future)` returns `False`
self.assertFalse(asyncio.isfuture(mock.Mock()))
f = self._new_future(loop=self.loop)
self.assertTrue(asyncio.isfuture(f))
self.assertFalse(asyncio.isfuture(type(f)))
# As `isinstance(Mock(Future), Future)` returns `True`
self.assertTrue(asyncio.isfuture(mock.Mock(type(f))))
f.cancel()
开发者ID:bkerler，项目名称:android_universal，代码行数:24，
示例3: test_api_calls_return_a_response_when_run_in_sync_mode
点赞 5
# 需要导入模块: import asyncio [as 别名]
# 或者: from asyncio import isfuture [as 别名]
def test_api_calls_return_a_response_when_run_in_sync_mode(self):
self.client.token = "xoxb-api_test"
resp = self.client.api_test()
self.assertFalse(asyncio.isfuture(resp))
self.assertTrue(resp["ok"])
开发者ID:slackapi，项目名称:python-slackclient，代码行数:7，
示例4: test_api_calls_return_a_future_when_run_in_async_mode
点赞 5
# 需要导入模块: import asyncio [as 别名]
# 或者: from asyncio import isfuture [as 别名]
def test_api_calls_return_a_future_when_run_in_async_mode(self):
self.client.token = "xoxb-api_test"
self.client.run_async = True
future = self.client.api_test()
self.assertTrue(asyncio.isfuture(future))
resp = await future
self.assertEqual(200, resp.status_code)
self.assertTrue(resp["ok"])
开发者ID:slackapi，项目名称:python-slackclient，代码行数:10，
示例5: _dispatch
点赞 5
# 需要导入模块: import asyncio [as 别名]
# 或者: from asyncio import isfuture [as 别名]
def _dispatch(self, f, value=None):
self._check_exhausted()
if f is None:
return
elif asyncio.isfuture(f):
f.set_result(value)
elif asyncio.iscoroutinefunction(f):
self.loop.create_task(f(value))
else:
f(value)
# self.loop.call_soon(functools.partial(f, value))
开发者ID:zh217，项目名称:aiochan，代码行数:14，
示例6: __init__
点赞 5
# 需要导入模块: import asyncio [as 别名]
# 或者: from asyncio import isfuture [as 别名]
def __init__(self, identifier, hashable_key, type_spec, target_future):
"""Creates a cached value.
Args:
identifier: An instance of `CachedValueIdentifier`.
hashable_key: A hashable source value key, if any, or `None` of not
applicable in this context, for use during cleanup.
type_spec: The type signature of the target, an instance of `tff.Type`.
target_future: An asyncio future that returns an instance of
`executor_value_base.ExecutorValue` that represents a value embedded in
the target executor.
Raises:
TypeError: If the arguments are of the wrong types.
"""
py_typecheck.check_type(identifier, CachedValueIdentifier)
py_typecheck.check_type(hashable_key, collections.Hashable)
py_typecheck.check_type(type_spec, computation_types.Type)
if not asyncio.isfuture(target_future):
raise TypeError('Expected an asyncio future, got {}'.format(
py_typecheck.type_string(type(target_future))))
self._identifier = identifier
self._hashable_key = hashable_key
self._type_spec = type_spec
self._target_future = target_future
self._computed_result = None
开发者ID:tensorflow，项目名称:federated，代码行数:28，
示例7: test_mock_from_create_future
点赞 5
# 需要导入模块: import asyncio [as 别名]
# 或者: from asyncio import isfuture [as 别名]
def test_mock_from_create_future(self, klass):
loop = asyncio.new_event_loop()
try:
if not (hasattr(loop, "create_future") and
hasattr(asyncio, "isfuture")):
return
mock = klass(loop.create_future())
self.assertTrue(asyncio.isfuture(mock))
finally:
loop.close()
开发者ID:Martiusweb，项目名称:asynctest，代码行数:14，
示例8: isfuture
点赞 5
# 需要导入模块: import asyncio [as 别名]
# 或者: from asyncio import isfuture [as 别名]
def isfuture(fut):
return isinstance(fut, asyncio.Future)
开发者ID:skylander86，项目名称:lambda-text-extractor，代码行数:4，
示例9: test_start_stop
点赞 5
# 需要导入模块: import asyncio [as 别名]
# 或者: from asyncio import isfuture [as 别名]
def test_start_stop(self):
self.assertTrue(asyncio.isfuture(self.order_book_tracker._order_book_snapshot_router_task))
self.order_book_tracker.stop()
self.assertIsNone(self.order_book_tracker._order_book_snapshot_router_task)
self.order_book_tracker.start()
开发者ID:CoinAlpha，项目名称:hummingbot，代码行数:7，
示例10: test_wrap_future
点赞 5
# 需要导入模块: import asyncio [as 别名]
# 或者: from asyncio import isfuture [as 别名]
def test_wrap_future(self):
def run(arg):
return (arg, threading.get_ident())
ex = concurrent.futures.ThreadPoolExecutor(1)
f1 = ex.submit(run, 'oi')
f2 = asyncio.wrap_future(f1, loop=self.loop)
res, ident = self.loop.run_until_complete(f2)
self.assertTrue(asyncio.isfuture(f2))
self.assertEqual(res, 'oi')
self.assertNotEqual(ident, threading.get_ident())
ex.shutdown(wait=True)
开发者ID:bkerler，项目名称:android_universal，代码行数:14，
注：本文中的asyncio.isfuture方法示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。
记得收藏哦...)
