##// END OF EJS Templates
allow utilities in test_message_spec to be reused...
MinRK -
Show More
@@ -46,7 +46,9 b' def teardown():'
46 46 KM.shutdown_kernel()
47 47
48 48
49 def flush_channels():
49 def flush_channels(km=None):
50 if km is None:
51 km = KM
50 52 """flush any messages waiting on the queue"""
51 53 for channel in (KM.shell_channel, KM.iopub_channel):
52 54 while True:
@@ -58,10 +60,12 b' def flush_channels():'
58 60 list(validate_message(msg))
59 61
60 62
61 def execute(code='', **kwargs):
63 def execute(code='', km=None, **kwargs):
62 64 """wrapper for doing common steps for validating an execution request"""
63 shell = KM.shell_channel
64 sub = KM.iopub_channel
65 if km is None:
66 km = KM
67 shell = km.shell_channel
68 sub = km.iopub_channel
65 69
66 70 msg_id = shell.execute(code=code, **kwargs)
67 71 reply = shell.get_msg(timeout=2)
General Comments 0
You need to be logged in to leave comments. Login now