Show More
@@ -10,7 +10,7 b' from session import extract_header, Session' | |||||
10 | class ZMQDisplayHook(object): |
|
10 | class ZMQDisplayHook(object): | |
11 | """A simple displayhook that publishes the object's repr over a ZeroMQ |
|
11 | """A simple displayhook that publishes the object's repr over a ZeroMQ | |
12 | socket.""" |
|
12 | socket.""" | |
13 |
topic= |
|
13 | topic=b'pyout' | |
14 |
|
14 | |||
15 | def __init__(self, session, pub_socket): |
|
15 | def __init__(self, session, pub_socket): | |
16 | self.session = session |
|
16 | self.session = session |
@@ -44,6 +44,7 b' class OutStream(object):' | |||||
44 | self.session = session |
|
44 | self.session = session | |
45 | self.pub_socket = pub_socket |
|
45 | self.pub_socket = pub_socket | |
46 | self.name = name |
|
46 | self.name = name | |
|
47 | self.topic = b'stream.' + py3compat.cast_bytes(name) | |||
47 | self.parent_header = {} |
|
48 | self.parent_header = {} | |
48 | self._new_buffer() |
|
49 | self._new_buffer() | |
49 | self._buffer_lock = threading.Lock() |
|
50 | self._buffer_lock = threading.Lock() |
@@ -61,7 +61,7 b' class ZMQDisplayPublisher(DisplayPublisher):' | |||||
61 | session = Instance(Session) |
|
61 | session = Instance(Session) | |
62 | pub_socket = Instance(SocketABC) |
|
62 | pub_socket = Instance(SocketABC) | |
63 | parent_header = Dict({}) |
|
63 | parent_header = Dict({}) | |
64 |
topic = CBytes(b'display |
|
64 | topic = CBytes(b'display_data') | |
65 |
|
65 | |||
66 | def set_parent(self, parent): |
|
66 | def set_parent(self, parent): | |
67 | """Set the parent for outbound messages.""" |
|
67 | """Set the parent for outbound messages.""" |
General Comments 0
You need to be logged in to leave comments.
Login now