We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e195cb7 commit 333a010Copy full SHA for 333a010
jupyter_client/blocking/client.py
@@ -16,8 +16,19 @@
16
from jupyter_client.client import KernelClient
17
from .channels import ZMQSocketChannel
18
19
+
20
class BlockingKernelClient(KernelClient):
21
+ """A BlockingKernelClient """
22
23
def wait_for_ready(self, timeout=None):
24
+ """Waits for a response when a client is blocked
25
26
+ - Sets future time for timeout
27
+ - Blocks on shell channel until a message is received
28
+ - Exit if the kernel has died
29
+ - If client times out before receiving a message from the kernel, send RuntimeError
30
+ - Flush the IOPub channel
31
+ """
32
if timeout is None:
33
abs_timeout = float('inf')
34
else:
0 commit comments