

def test_invalid_endpoint():
    (server, session, transport, conn) = _get_test_environment()
    transport.recv(proto.message('test', 'abc'))
    eq_(len(conn.incoming), 0)

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