

def getstream(address):
    c = zmq.Context()
    s = c.socket(zmq.SUB)
    s.setsockopt(zmq.SUBSCRIBE, '')
    s.connect(address)
    while True:
        (yield s.recv())

dataset/ETHPy150Open sailthru/relay/bin/debugger.py getstream/original