Module: kernel.blocking.channels

Blocking channels

Useful for test suites and blocking terminal interfaces.

5 Classes

class IPython.kernel.blocking.channels.BlockingChannelMixin(*args, **kwds)

Bases: object

__init__(*args, **kwds)

get_msg(block=True, timeout=None)

Gets a message if there is one that is ready.

get_msgs()

Get all messages that are currently ready.

msg_ready()

Is there a message that has been received?

class IPython.kernel.blocking.channels.BlockingIOPubChannel(*args, **kwds)

Bases: IPython.kernel.blocking.channels.BlockingChannelMixin, IPython.kernel.channels.IOPubChannel

class IPython.kernel.blocking.channels.BlockingShellChannel(*args, **kwds)

Bases: IPython.kernel.blocking.channels.BlockingChannelMixin, IPython.kernel.channels.ShellChannel

class IPython.kernel.blocking.channels.BlockingStdInChannel(*args, **kwds)

Bases: IPython.kernel.blocking.channels.BlockingChannelMixin, IPython.kernel.channels.StdInChannel

class IPython.kernel.blocking.channels.BlockingHBChannel(context, session, address)

Bases: IPython.kernel.channels.HBChannel

call_handlers(since_last_heartbeat)

Pause beating on missed heartbeat.