Gecko [ lorencats.com ]

Name	Size	Permission
__pycache__	[ DIR ]	drwxr-xr-x
comm	[ DIR ]	drwxr-xr-x
gui	[ DIR ]	drwxr-xr-x
inprocess	[ DIR ]	drwxr-xr-x
pylab	[ DIR ]	drwxr-xr-x
resources	[ DIR ]	drwxr-xr-x
tests	[ DIR ]	drwxr-xr-x
__init__.py	125 B	-rw-r--r--
__main__.py	100 B	-rw-r--r--
_eventloop_macos.py	3.95 KB	-rw-r--r--
_version.py	176 B	-rw-r--r--
codeutil.py	1.27 KB	-rw-r--r--
connect.py	6.1 KB	-rw-r--r--
datapub.py	1.89 KB	-rw-r--r--
displayhook.py	2.62 KB	-rw-r--r--
embed.py	2.01 KB	-rw-r--r--
eventloops.py	10.62 KB	-rw-r--r--
heartbeat.py	2.35 KB	-rw-r--r--
iostream.py	14.83 KB	-rw-r--r--
ipkernel.py	14.99 KB	-rw-r--r--
jsonutil.py	6.37 KB	-rw-r--r--
kernelapp.py	19.96 KB	-rw-r--r--
kernelbase.py	27.18 KB	-rw-r--r--
kernelspec.py	6.47 KB	-rw-r--r--
log.py	766 B	-rw-r--r--
parentpoller.py	4.08 KB	-rw-r--r--
pickleutil.py	12.66 KB	-rw-r--r--
serialize.py	5.99 KB	-rw-r--r--
zmqshell.py	21.2 KB	-rw-r--r--

Code Editor : displayhook.py

"""Replacements for sys.displayhook that publish over ZMQ."""

# Copyright (c) IPython Development Team.
# Distributed under the terms of the Modified BSD License.

import sys

from IPython.core.displayhook import DisplayHook
from ipykernel.jsonutil import encode_images, json_clean
from ipython_genutils.py3compat import builtin_mod
from traitlets import Instance, Dict, Any
from jupyter_client.session import extract_header, Session

class ZMQDisplayHook(object):
    """A simple displayhook that publishes the object's repr over a ZeroMQ
    socket."""
    topic = b'execute_result'

def __init__(self, session, pub_socket):
        self.session = session
        self.pub_socket = pub_socket
        self.parent_header = {}

def get_execution_count(self):
        """This method is replaced in kernelapp"""
        return 0

def __call__(self, obj):
        if obj is None:
            return

builtin_mod._ = obj
        sys.stdout.flush()
        sys.stderr.flush()
        contents = {u'execution_count': self.get_execution_count(),
                    u'data': {'text/plain': repr(obj)},
                    u'metadata': {}}
        self.session.send(self.pub_socket, u'execute_result', contents,
                          parent=self.parent_header, ident=self.topic)

def set_parent(self, parent):
        self.parent_header = extract_header(parent)

class ZMQShellDisplayHook(DisplayHook):
    """A displayhook subclass that publishes data using ZeroMQ. This is intended
    to work with an InteractiveShell instance. It sends a dict of different
    representations of the object."""
    topic=None

session = Instance(Session, allow_none=True)
    pub_socket = Any(allow_none=True)
    parent_header = Dict({})

def set_parent(self, parent):
        """Set the parent for outbound messages."""
        self.parent_header = extract_header(parent)

def start_displayhook(self):
        self.msg = self.session.msg(u'execute_result', {
            'data': {},
            'metadata': {},
        }, parent=self.parent_header)

def write_output_prompt(self):
        """Write the output prompt."""
        self.msg['content']['execution_count'] = self.prompt_count

def write_format_data(self, format_dict, md_dict=None):
        self.msg['content']['data'] = json_clean(encode_images(format_dict))
        self.msg['content']['metadata'] = md_dict

def finish_displayhook(self):
        """Finish up all displayhook activities."""
        sys.stdout.flush()
        sys.stderr.flush()
        if self.msg['content']['data']:
            self.session.send(self.pub_socket, self.msg, ident=self.topic)
        self.msg = None

${this.title}

Code Editor : displayhook.py