async def METHOD_NAME(event_loop, sleeper=asyncio.sleep):
    pubnub = PubNubAsyncio(pnconf_sub_copy(), custom_event_loop=event_loop)
    pubnub.config.uuid = 'test-here-now-asyncio-uuid1'
    ch1 = "test-here-now-asyncio-ch1"
    ch2 = "test-here-now-asyncio-ch2"
    callback = VCR599Listener(1)
    pubnub.add_listener(callback)
    pubnub.subscribe().channels([ch1, ch2]).execute()
    await callback.wait_for_connect()
    await sleeper(5)
    env = await pubnub.here_now() \
        .channels([ch1, ch2]) \
        .future()
    assert env.result.total_channels == 2
    assert env.result.total_occupancy >= 1
    channels = env.result.channels
    assert len(channels) == 2
    assert channels[0].occupancy == 1
    assert channels[0].occupants[0].uuid == pubnub.uuid
    assert channels[1].occupancy == 1
    assert channels[1].occupants[0].uuid == pubnub.uuid
    result = await pubnub.here_now() \
        .channels([ch1, ch2]) \
        .include_state(True) \
        .result()
    assert result.total_channels == 2
    pubnub.unsubscribe().channels([ch1, ch2]).execute()
    await callback.wait_for_disconnect()
    await pubnub.stop()