minrk

import os

from IPython.frontend.qt.console.rich_ipython_widget import RichIPythonWidget
from IPython.frontend.qt.kernelmanager import QtKernelManager
from IPython.frontend.qt.inprocess_kernelmanager import QtInProcessKernelManager
from IPython.kernel.zmq.ipkernel import Kernel
from IPython.kernel.inprocess.ipkernel import InProcessKernel
from IPython.lib import guisupport

minrk

minrk

import json, time, threading

import zmq
from zmq.eventloop import ioloop, zmqstream

class Logger( threading.Thread ):
    def __init__( self, *args, **kwargs ):
        threading.Thread.__init__( self )
        self.rtrSocket = None
        self.stream = None

minrk

import zmq
from zmq.eventloop import zmqstream, ioloop
import threading

import logging
logging.basicConfig(level=logging.DEBUG)
logger = logging.getLogger()

# run ioloop in separate thread
def threaded_loop():

minrk

from IPython.frontend.qt.console.qtconsoleapp import IPythonQtConsoleApp
a = IPythonQtConsoleApp()
a.initialize()
# load the sympyprinting extension in the kernel before starting
a.kernel_manager.shell_channel.execute("%load_ext sympyprinting", silent=True)
a.start()

minrk

"""
A test forking server

To start a single kernel by forking, do::

    python -i testfork.py
    
The kernel object will be in the ``a`` variable.  When you close the 
python session, the forked kernel will be killed.
"""

minrk

import thread
import time
import zmq

# global zmg context
context = zmq.Context()
endpoint = "tcp://*:8888"

# the subscriber thread function
def subscriber(name, address, cnt, subscriptions):

minrk

import os
import sys

import numpy as np
import matplotlib.pyplot as plt

from pandas import DataFrame
from pandas.util.testing import set_trace

dirs = []

minrk

# override ioloop.IOLoop with zmq's IOLoop
import sys
import tornado.ioloop
from zmq.eventloop import ioloop
tornado.ioloop.IOLoop = ioloop.IOLoop

import trombi

loop = ioloop.IOLoop.instance()
# check that tornado's ioloop instance is actually zmq's

minrk

#!/usr/bin/python
"""
zmq_cli - 0MQ Server interruptability test case, client module.

"""


import zmq