def _set_future()

in pulsar/asyncio.py [0:0]

• 7 lines of code
• 2 McCabe index (conditional complexity)

def _set_future(future: asyncio.Future, result: _pulsar.Result, value: Any):
    def complete():
        if result == _pulsar.Result.Ok:
            future.set_result(value)
        else:
            future.set_exception(PulsarException(result))
    future.get_loop().call_soon_threadsafe(complete)