##// END OF EJS Templates
close KernelManager channel sockets when they stop...
close KernelManager channel sockets when they stop Otherwise there are dangling sockets on the Context, which cannot terminate.

File last commit:

r5390:c82649ea
r6564:df2592cb
Show More
payload.py
41 lines | 1.2 KiB | text/x-python | PythonLexer
Brian Granger
Adding payload module.
r2807 # -*- coding: utf-8 -*-
"""Payload system for IPython.
Authors:
* Fernando Perez
* Brian Granger
"""
#-----------------------------------------------------------------------------
Matthias BUSSONNIER
update copyright to 2011/20xx-2011...
r5390 # Copyright (C) 2008-2011 The IPython Development Team
Brian Granger
Adding payload module.
r2807 #
# Distributed under the terms of the BSD License. The full license is in
# the file COPYING, distributed as part of this software.
#-----------------------------------------------------------------------------
#-----------------------------------------------------------------------------
# Imports
#-----------------------------------------------------------------------------
from IPython.config.configurable import Configurable
Brian Granger
Fixing imports and syntax errors.
r2812 from IPython.utils.traitlets import List
Brian Granger
Adding payload module.
r2807
#-----------------------------------------------------------------------------
# Main payload class
#-----------------------------------------------------------------------------
class PayloadManager(Configurable):
Brian Granger
Fixing imports and syntax errors.
r2812 _payload = List([])
Brian Granger
Adding payload module.
r2807
Brian Granger
Fixing imports and syntax errors.
r2812 def write_payload(self, data):
if not isinstance(data, dict):
raise TypeError('Each payload write must be a dict, got: %r' % data)
Brian Granger
First working draft of new payload system.
r2814 self._payload.append(data)
Brian Granger
Adding payload module.
r2807
def read_payload(self):
return self._payload
Brian Granger
First working draft of new payload system.
r2814
def clear_payload(self):
self._payload = []