@Test
public void testFindAssetsByTenantIdAndIdsAsync() throws ExecutionException, InterruptedException {

    UUID tenantId = UUIDs.timeBased();
    UUID customerId = UUIDs.timeBased();
    List<UUID> searchIds = new ArrayList<>();
    for (int i = 0; i < 30; i++) {
        UUID assetId = UUIDs.timeBased();
        saveAsset(assetId, tenantId, customerId, "ASSET_" + i, "TYPE_1");
        if (i % 3 == 0) {
            searchIds.add(assetId);
        }
    }
    ListenableFuture<List<Asset>> assetsFuture = assetDao
            .findAssetsByTenantIdAndIdsAsync(tenantId, searchIds);
    List<Asset> assets = assetsFuture.get();
    assertNotNull(assets);
    assertEquals(10, assets.size());
}