async def METHOD_NAME(event_loop, client_id):
    """Create a stan connection for each function, to be used in the tests."""
    nc = Nats()
    sc = Stan()
    cluster_name = 'test-cluster'
    await nc.connect(io_loop=event_loop, name='entity.filing.tester')
    await sc.connect(cluster_name, client_id, nats=nc)
    yield sc
    await sc.close()
    await nc.close()