Asyncio Support For ZeroMQ-Based Kernels

[peteut]

Is there a chance to get native support for asyncio support for zeroMQ-based kernels?

I came up with this, which works already quite nice (needed a quick solution).

import asyncio
import itertools
from IPython.kernel.zmq.eventloops import register_integration


# FIXME: needs cleanup!
# https://github.com/ipython/ipykernel/blob/197a4a81c38dfcafb1cddb3029329137c8748b23/ipykernel/eventloops.py


@register_integration('asyncio')
def loop_asyncio(kernel):
    '''Start a kernel with asyncio event loop support.'''
    loop = asyncio.get_event_loop()

    def kernel_handler():
        loop.call_soon(kernel.do_one_iteration)
        loop.call_later(kernel._poll_interval, kernel_handler)

    loop.call_soon(kernel_handler)
    try:
        if not loop.is_running():
            loop.run_forever()
    finally:
        loop.close()

Invoking this cell prior the %gui asyncio cell already did the job.

[takluyver]

I made a very experimental asyncio kernel, but I wouldn't recommend that anyone use it seriously.

What are you trying to do with asyncio integration?

[peteut]

Thanks for the link, I'll give it a try!

My scenario is this:
I have a Notebook with some interactive widgets and some asyncio.coroutine.
The master coroutine checks some widget state and joins the workers/tasks upon request.

[jasongrout]

We've now merged this in #246. Thanks again!

[jasongrout]

Note that I also wrote a short notebook illustrating some ways the widgets can be used asynchronously at https://github.com/jupyter-widgets/ipywidgets/blob/master/docs/source/examples/Widget%20Asynchronous.ipynb