

@raises(TypeError)
def test_failed_event():
    (server, session, transport, conn) = _get_test_environment(EventConnection)
    transport.recv(proto.event(None, 'test', None, a=10, b=20))
    eq_(transport.pop_outgoing(), proto.event(None, 'test', None, a=10, b=20))
    transport.recv(proto.event(None, 'test', None, a=10))

dataset/ETHPy150Open mrjoes/tornadio2/tests/session_test.py test_failed_event/original