environment/lib/python2.7/site-packages/IPython/frontend/terminal/console/interactiveshell.py
def handle_iopub(self):
        """ Method to procces subscribe channel's messages

           This method reads a message and processes the content in different
           outputs like stdout, stderr, pyout and status

           Arguments:
           sub_msg:  message receive from kernel in the sub socket channel
                     capture by kernel manager.
        """
        while self.km.sub_channel.msg_ready():
            sub_msg = self.km.sub_channel.get_msg()
            msg_type = sub_msg['header']['msg_type']
            parent = sub_msg["parent_header"]
            if (not parent) or self.session_id == parent['session']:
                if msg_type == 'status' :
                    if sub_msg["content"]["execution_state"] == "busy" :
                        pass

                elif msg_type == 'stream' :
                    if sub_msg["content"]["name"] == "stdout":
                        print(sub_msg["content"]["data"], file=io.stdout, end="")
                        io.stdout.flush()
                    elif sub_msg["content"]["name"] == "stderr" :
                        print(sub_msg["content"]["data"], file=io.stderr, end="")
                        io.stderr.flush()

                elif msg_type == 'pyout':
                    self.execution_count = int(sub_msg["content"]["execution_count"])
                    format_dict = sub_msg["content"]["data"]
                    # taken from DisplayHook.__call__:
                    hook = self.displayhook
                    hook.start_displayhook()
                    hook.write_output_prompt()
                    hook.write_format_data(format_dict)
                    hook.log_output(format_dict)
                    hook.finish_displayhook()
def handle_iopub(self):
        """ Method to procces subscribe channel's messages

           This method reads a message and processes the content in different
           outputs like stdout, stderr, pyout and status

           Arguments:
           sub_msg:  message receive from kernel in the sub socket channel
                     capture by kernel manager.
        """
        while self.km.sub_channel.msg_ready():
            sub_msg = self.km.sub_channel.get_msg()
            msg_type = sub_msg['header']['msg_type']
            parent = sub_msg["parent_header"]
            if (not parent) or self.session_id == parent['session']:
                if msg_type == 'status' :
                    if sub_msg["content"]["execution_state"] == "busy" :
                        pass

                elif msg_type == 'stream' :
                    if sub_msg["content"]["name"] == "stdout":
                        print(sub_msg["content"]["data"], file=io.stdout, end="")
                        io.stdout.flush()
                    elif sub_msg["content"]["name"] == "stderr" :
                        print(sub_msg["content"]["data"], file=io.stderr, end="")
                        io.stderr.flush()

                elif msg_type == 'pyout':
                    self.execution_count = int(sub_msg["content"]["execution_count"])
                    format_dict = sub_msg["content"]["data"]
                    # taken from DisplayHook.__call__:
                    hook = self.displayhook
                    hook.start_displayhook()
                    hook.write_output_prompt()
                    hook.write_format_data(format_dict)
                    hook.log_output(format_dict)
                    hook.finish_displayhook()
def handle_iopub ( self ) : while self . km . sub_channel . msg_ready ( ) : sub_msg = self . km . sub_channel . get_msg ( ) msg_type = sub_msg [ 'header' ] [ 'msg_type' ] parent = sub_msg [ "parent_header" ] if ( not parent ) or self . session_id == parent [ 'session' ] : if msg_type == 'status' : if sub_msg [ "content" ] [ "execution_state" ] == "busy" : pass elif msg_type == 'stream' : if sub_msg [ "content" ] [ "name" ] == "stdout" : print ( sub_msg [ "content" ] [ "data" ] , file = io . stdout , end = "" ) io . stdout . flush ( ) elif sub_msg [ "content" ] [ "name" ] == "stderr" : print ( sub_msg [ "content" ] [ "data" ] , file = io . stderr , end = "" ) io . stderr . flush ( ) elif msg_type == 'pyout' : self . execution_count = int ( sub_msg [ "content" ] [ "execution_count" ] ) format_dict = sub_msg [ "content" ] [ "data" ] # taken from DisplayHook.__call__: hook = self . displayhook hook . start_displayhook ( ) hook . write_output_prompt ( ) hook . write_format_data ( format_dict ) hook . log_output ( format_dict ) hook . finish_displayhook ( )
Method to procces subscribe channel's messages

           This method reads a message and processes the content in different
           outputs like stdout, stderr, pyout and status

           Arguments:
           sub_msg:  message receive from kernel in the sub socket channel
                     capture by kernel manager.
Method to procces subscribe channel s messages