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 : datapub.py

"""Publishing native (typically pickled) objects.
"""

import warnings
warnings.warn("ipykernel.datapub is deprecated. It has moved to ipyparallel.datapub", DeprecationWarning)

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

from traitlets.config import Configurable
from traitlets import Instance, Dict, CBytes, Any
from ipykernel.jsonutil import json_clean
from ipykernel.serialize import serialize_object
from jupyter_client.session import Session, extract_header

class ZMQDataPublisher(Configurable):

topic = topic = CBytes(b'datapub')
    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 publish_data(self, data):
        """publish a data_message on the IOPub channel

Parameters
        ----------

data : dict
            The data to be published. Think of it as a namespace.
        """
        session = self.session
        buffers = serialize_object(data,
            buffer_threshold=session.buffer_threshold,
            item_threshold=session.item_threshold,
        )
        content = json_clean(dict(keys=list(data.keys())))
        session.send(self.pub_socket, 'data_message', content=content,
            parent=self.parent_header,
            buffers=buffers,
            ident=self.topic,
        )

def publish_data(data):
    """publish a data_message on the IOPub channel

Parameters
    ----------

data : dict
        The data to be published. Think of it as a namespace.
    """
    warnings.warn("ipykernel.datapub is deprecated. It has moved to ipyparallel.datapub", DeprecationWarning)
    
    from ipykernel.zmqshell import ZMQInteractiveShell
    ZMQInteractiveShell.instance().data_pub.publish_data(data)

${this.title}

Code Editor : datapub.py