B U[@sdZddlZededdlmZddlmZmZm Z m Z ddl m Z ddl mZddlmZmZGd d d eZd d ZdS) z/Publishing native (typically pickled) objects. NzDipykernel.datapub is deprecated. It has moved to ipyparallel.datapub) Configurable)InstanceDictCBytesAny) json_clean)serialize_object)Sessionextract_headerc@sFeZdZedZZeeddZeddZ e iZ ddZ ddZ dS) ZMQDataPublishersdatapubT)Z allow_nonecCst||_dS)z%Set the parent for outbound messages.N)r parent_header)selfparentr0lib/python3.7/site-packages/ipykernel/datapub.py set_parentszZMQDataPublisher.set_parentcCsN|j}t||j|jd}ttt|d}|j|j d||j ||j ddS)zpublish a data_message on the IOPub channel Parameters ---------- data : dict The data to be published. Think of it as a namespace. )buffer_thresholditem_threshold)keysZ data_message)contentrbuffersZidentN) sessionrrrrdictlistrsend pub_socketr topic)r datarrrrrr publish_datas   zZMQDataPublisher.publish_dataN)__name__ __module__ __qualname__rrrr rrrrr rrrrrrr s    r cCs,tdtddlm}|j|dS)zpublish a data_message on the IOPub channel Parameters ---------- data : dict The data to be published. Think of it as a namespace. zDipykernel.datapub is deprecated. It has moved to ipyparallel.datapubr)ZMQInteractiveShellN)warningswarnDeprecationWarningZipykernel.zmqshellr"instanceZdata_pubr)rr"rrrr2s  r)__doc__r#r$r%Ztraitlets.configrZ traitletsrrrrZipykernel.jsonutilrZipykernel.serializerZjupyter_client.sessionr r r rrrrrs    !