Show More
@@ -45,12 +45,9 b' def validate_string_dict(dct):' | |||
|
45 | 45 | |
|
46 | 46 | class ZMQSocketChannel(object): |
|
47 | 47 | """The base class for the channels that use ZMQ sockets.""" |
|
48 | context = None | |
|
49 | 48 | session = None |
|
50 | 49 | socket = None |
|
51 | ioloop = None | |
|
52 | 50 | stream = None |
|
53 | _address = None | |
|
54 | 51 | _exiting = False |
|
55 | 52 | proxy_methods = [] |
|
56 | 53 | |
@@ -67,7 +64,6 b' class ZMQSocketChannel(object):' | |||
|
67 | 64 | Standard (ip, port) tuple that the kernel is listening on. |
|
68 | 65 | """ |
|
69 | 66 | super(ZMQSocketChannel, self).__init__() |
|
70 | self.daemon = True | |
|
71 | 67 | |
|
72 | 68 | self.socket = socket |
|
73 | 69 | self.session = session |
@@ -134,30 +130,6 b' class ZMQSocketChannel(object):' | |||
|
134 | 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 | 134 | class BlockingHBChannel(HBChannel): |
|
163 | 135 |
General Comments 0
You need to be logged in to leave comments.
Login now