Show More
@@ -45,12 +45,9 b' def validate_string_dict(dct):' | |||||
45 |
|
45 | |||
46 | class ZMQSocketChannel(object): |
|
46 | class ZMQSocketChannel(object): | |
47 | """The base class for the channels that use ZMQ sockets.""" |
|
47 | """The base class for the channels that use ZMQ sockets.""" | |
48 | context = None |
|
|||
49 | session = None |
|
48 | session = None | |
50 | socket = None |
|
49 | socket = None | |
51 | ioloop = None |
|
|||
52 | stream = None |
|
50 | stream = None | |
53 | _address = None |
|
|||
54 | _exiting = False |
|
51 | _exiting = False | |
55 | proxy_methods = [] |
|
52 | proxy_methods = [] | |
56 |
|
53 | |||
@@ -67,7 +64,6 b' class ZMQSocketChannel(object):' | |||||
67 | Standard (ip, port) tuple that the kernel is listening on. |
|
64 | Standard (ip, port) tuple that the kernel is listening on. | |
68 | """ |
|
65 | """ | |
69 | super(ZMQSocketChannel, self).__init__() |
|
66 | super(ZMQSocketChannel, self).__init__() | |
70 | self.daemon = True |
|
|||
71 |
|
67 | |||
72 | self.socket = socket |
|
68 | self.socket = socket | |
73 | self.session = session |
|
69 | self.session = session | |
@@ -134,30 +130,6 b' class ZMQSocketChannel(object):' | |||||
134 | pass |
|
130 | pass | |
135 |
|
131 | |||
136 |
|
132 | |||
137 | class BlockingShellChannel(ZMQSocketChannel): |
|
|||
138 | """The shell channel for issuing request/replies to the kernel.""" |
|
|||
139 |
|
||||
140 | def start(self): |
|
|||
141 | self.socket = make_stdin_socket(self.context, self.session.bsession, self.address) |
|
|||
142 |
|
||||
143 |
|
||||
144 | class BlockingIOPubChannel(ZMQSocketChannel): |
|
|||
145 | """The iopub channel which listens for messages that the kernel publishes. |
|
|||
146 |
|
||||
147 | This channel is where all output is published to frontends. |
|
|||
148 | """ |
|
|||
149 | def start(self): |
|
|||
150 | self.socket = make_iopub_socket(self.context, self.session.bsession, self.address) |
|
|||
151 |
|
||||
152 | class BlockingStdInChannel(ZMQSocketChannel): |
|
|||
153 | """The stdin channel to handle raw_input requests that the kernel makes.""" |
|
|||
154 | def start(self): |
|
|||
155 | self.socket = make_stdin_socket(self.context, self.session.bsession, self.address) |
|
|||
156 |
|
||||
157 | ShellChannelABC.register(BlockingShellChannel) |
|
|||
158 | IOPubChannelABC.register(BlockingIOPubChannel) |
|
|||
159 | StdInChannelABC.register(BlockingStdInChannel) |
|
|||
160 |
|
||||
161 |
|
133 | |||
162 | class BlockingHBChannel(HBChannel): |
|
134 | class BlockingHBChannel(HBChannel): | |
163 |
|
135 |
General Comments 0
You need to be logged in to leave comments.
Login now