io.vertx.core.json.JsonArray.addAll()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(8.9k)|赞(0)|评价(0)|浏览(73)

本文整理了Java中io.vertx.core.json.JsonArray.addAll()方法的一些代码示例，展示了JsonArray.addAll()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。JsonArray.addAll()方法的具体详情如下：
包路径：io.vertx.core.json.JsonArray
类名称：JsonArray
方法名：addAll

JsonArray.addAll介绍

[英]Appends all of the elements in the specified array to the end of this JSON array.
[中]将指定数组中的所有元素追加到此JSON数组的末尾。

代码示例

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testAddAllJsonArray() {
 jsonArray.add("bar");
 JsonArray arr = new JsonArray().add("foo").add(48);
 assertSame(jsonArray, jsonArray.addAll(arr));
 assertEquals(arr.getString(0), jsonArray.getString(1));
 assertEquals(arr.getInteger(1), jsonArray.getInteger(2));
 try {
  jsonArray.add((JsonArray)null);
  fail();
 } catch (NullPointerException e) {
  // OK
 }
}

代码示例来源：origin: xenv/gushici

/**
 * @param message example: {format: "png", categories: [shenghuo, buyi]}
 */
private void getGushiciFromRedis(Message<JsonObject> message) {
  JsonArray realCategory = new JsonArray()
    .add("png".equals(message.body().getString("format")) ? "img" : "json")
    .addAll(message.body().getJsonArray("categories"));
  checkAndGetKey(realCategory)
    .compose(key -> Future.<String>future(s -> redisClient.srandmember(key, s))) // 从 set 随机返回一个对象
    .setHandler(res -> {
      if (res.succeeded()) {
        message.reply(res.result());
      } else {
        if (res.cause() instanceof ReplyException) {
          ReplyException exception = (ReplyException) res.cause();
          message.fail(exception.failureCode(), exception.getMessage());
        }
        message.fail(500, res.cause().getMessage());
      }
    });
}

代码示例来源：origin: xenv/gushici

@Override
public void start(Future<Void> startFuture) {
  vertx.eventBus().consumer(Key.GET_GUSHICI_FROM_REDIS, this::getGushiciFromRedis);
  vertx.eventBus().consumer(Key.GET_HELP_FROM_REDIS, this::getHelpFromRedis);
  redisClient = RedisClient.create(vertx, redisOptions);
  // 从 redis 缓存所有 key
  Future<JsonArray> imgKeys = Future.future(f -> redisClient.keys(Key.IMG, f));
  Future<JsonArray> jsonKeys = Future.future(f -> redisClient.keys(Key.JSON, f));
  CompositeFuture.all(Arrays.asList(imgKeys, jsonKeys)).setHandler(v -> {
    if (v.succeeded()) {
      imgKeys.result().addAll(jsonKeys.result())
        .stream()
        .forEach(key -> keysInRedis.insert((String) key));
      startFuture.complete();
    } else {
      log.error("DataService fail to start", v.cause());
      startFuture.fail(v.cause());
    }
  });
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testAddAllJsonArray() {
 jsonArray.add("bar");
 JsonArray arr = new JsonArray().add("foo").add(48);
 assertSame(jsonArray, jsonArray.addAll(arr));
 assertEquals(arr.getString(0), jsonArray.getString(1));
 assertEquals(arr.getInteger(1), jsonArray.getInteger(2));
 try {
  jsonArray.add((JsonArray)null);
  fail();
 } catch (NullPointerException e) {
  // OK
 }
}

代码示例来源：origin: silentbalanceyh/vertx-zero

static JsonArray toJArray(final Object value) {
  final JsonArray result = new JsonArray();
  Fn.safeNull(() -> {
    if (Types.isJArray(value)) {
      result.addAll((JsonArray) value);
    } else {
      result.add(value.toString());
    }
  }, value);
  return result;
}

代码示例来源：origin: cn.vertxup/vertx-co

static JsonArray toJArray(final Object value) {
  final JsonArray result = new JsonArray();
  Fn.safeNull(() -> {
    if (Types.isJArray(value)) {
      result.addAll((JsonArray) value);
    } else {
      result.add(value.toString());
    }
  }, value);
  return result;
}

代码示例来源：origin: cn.vertxup/vertx-co

static JsonArray filter(
    final JsonArray array,
    final Predicate<JsonObject> testFun,
    final boolean immutable
) {
  final JsonArray result = immutable ? array.copy() : array;
  final JsonArray filtered = new JsonArray();
  Observable.fromIterable(result)
      .map(item -> (JsonObject) item)
      .filter(testFun::test)
      .subscribe(filtered::add).dispose();
  result.clear().addAll(filtered);
  return result;
}

代码示例来源：origin: cn.vertxup/vertx-co

static JsonArray vertical(
    final JsonArray array,
    final String field,
    final boolean immutable
) {
  final JsonArray result = immutable ? array.copy() : array;
  final JsonArray processed = new JsonArray();
  // TODO: handle [null] value at line: 178
  Observable.fromIterable(result)
      .map((item) -> (JsonObject) item)
      .map(item -> item.getValue(field))
      .subscribe(processed::add).dispose();
  result.clear().addAll(processed);
  return result;
}

代码示例来源：origin: silentbalanceyh/vertx-zero

static JsonArray sort(
      final JsonArray array,
      final boolean immutable
  ) {
    final JsonArray result = immutable ? array.copy() : array;
    final JsonArray dis = new JsonArray();
    Observable.fromIterable(result)
        .sorted()
        .subscribe(dis::add).dispose();
    return result.clear().addAll(dis);
  }
}

代码示例来源：origin: silentbalanceyh/vertx-zero

static JsonArray vertical(
    final JsonArray array,
    final String field,
    final boolean immutable
) {
  final JsonArray result = immutable ? array.copy() : array;
  final JsonArray processed = new JsonArray();
  // TODO: handle [null] value at line: 178
  Observable.fromIterable(result)
      .map((item) -> (JsonObject) item)
      .map(item -> item.getValue(field))
      .subscribe(processed::add).dispose();
  result.clear().addAll(processed);
  return result;
}

代码示例来源：origin: cn.vertxup/vertx-co

static JsonArray distinct(
    final JsonArray array,
    final boolean immutable
) {
  final JsonArray result = immutable ? array.copy() : array;
  final JsonArray dis = new JsonArray();
  Observable.fromIterable(result)
      .distinct()
      .subscribe(dis::add).dispose();
  return result.clear().addAll(dis);
}

代码示例来源：origin: cn.vertxup/vertx-co

static JsonArray sort(
      final JsonArray array,
      final boolean immutable
  ) {
    final JsonArray result = immutable ? array.copy() : array;
    final JsonArray dis = new JsonArray();
    Observable.fromIterable(result)
        .sorted()
        .subscribe(dis::add).dispose();
    return result.clear().addAll(dis);
  }
}

代码示例来源：origin: silentbalanceyh/vertx-zero

static JsonArray distinct(
    final JsonArray array,
    final boolean immutable
) {
  final JsonArray result = immutable ? array.copy() : array;
  final JsonArray dis = new JsonArray();
  Observable.fromIterable(result)
      .distinct()
      .subscribe(dis::add).dispose();
  return result.clear().addAll(dis);
}

代码示例来源：origin: silentbalanceyh/vertx-zero

static JsonArray filter(
    final JsonArray array,
    final Predicate<JsonObject> testFun,
    final boolean immutable
) {
  final JsonArray result = immutable ? array.copy() : array;
  final JsonArray filtered = new JsonArray();
  Observable.fromIterable(result)
      .map(item -> (JsonObject) item)
      .filter(testFun::test)
      .subscribe(filtered::add).dispose();
  result.clear().addAll(filtered);
  return result;
}

代码示例来源：origin: silentbalanceyh/vertx-zero

static JsonArray zip(
    final JsonArray targetArray,
    final JsonArray sources
) {
  final JsonArray results = new JsonArray();
  Ut.itJArray(targetArray, JsonObject.class, (source, index) -> {
    final JsonObject target = sources.getJsonObject(index);
    final JsonObject result = null == target ? source :
        append(source, target, true);
    results.add(result);
  });
  targetArray.clear();
  return targetArray.addAll(results);
}

代码示例来源：origin: cn.vertxup/vertx-co

static JsonArray zip(
    final JsonArray targetArray,
    final JsonArray sources
) {
  final JsonArray results = new JsonArray();
  Ut.itJArray(targetArray, JsonObject.class, (source, index) -> {
    final JsonObject target = sources.getJsonObject(index);
    final JsonObject result = null == target ? source :
        append(source, target, true);
    results.add(result);
  });
  targetArray.clear();
  return targetArray.addAll(results);
}

代码示例来源：origin: georocket/georocket

/**
  * Optimize an array of queries
  * @param children the queries to optimize
  * @param parentClause the parent clause in which the children are embedded
  * @return the optimized queries
  */
 private static JsonArray optimizeChildren(JsonArray children, String parentClause) {
  JsonArray copy = new JsonArray();
  for (int i = 0; i < children.size(); ++i) {
   Object c = children.getValue(i);
   Object newc = optimizeChildren(c, parentClause);
   if (newc instanceof JsonArray) {
    // merge optimized array into this one
    copy.addAll((JsonArray)newc);
   } else {
    copy.add(newc);
   }
  }
  return copy;
 }
}

代码示例来源：origin: eclipse/hono

final JsonArray credentialsArray = new JsonArray();
for (final JsonArray singleAuthIdCredentials : entry.getValue().values()) {
  credentialsArray.addAll(singleAuthIdCredentials.copy());
  idCount.incrementAndGet();

代码示例来源：origin: silentbalanceyh/vertx-zero

static JsonArray zip(
    final JsonArray target,
    final JsonArray sources,
    final String fromKey,
    final String toKey
) {
  final ConcurrentMap<Integer, Object> targetMap = mapIndex(target, fromKey);
  final ConcurrentMap<Object, JsonObject> sourceMap = mapZip(sources, toKey);
  final ConcurrentMap<Integer, JsonObject> merged = Ut.reduce(targetMap, sourceMap);
  final JsonArray results = new JsonArray();
  for (int idx = 0; idx < target.size(); idx++) {
    final JsonObject targetItem = merged.get(idx);
    final JsonObject sourceItem = target.getJsonObject(idx);
    final JsonObject item = null == targetItem ? sourceItem :
        append(sourceItem, targetItem, true);
    results.add(item);
  }
  target.clear();
  return target.addAll(results);
}

代码示例来源：origin: cn.vertxup/vertx-co

static JsonArray zip(
    final JsonArray target,
    final JsonArray sources,
    final String fromKey,
    final String toKey
) {
  final ConcurrentMap<Integer, Object> targetMap = mapIndex(target, fromKey);
  final ConcurrentMap<Object, JsonObject> sourceMap = mapZip(sources, toKey);
  final ConcurrentMap<Integer, JsonObject> merged = Ut.reduce(targetMap, sourceMap);
  final JsonArray results = new JsonArray();
  for (int idx = 0; idx < target.size(); idx++) {
    final JsonObject targetItem = merged.get(idx);
    final JsonObject sourceItem = target.getJsonObject(idx);
    final JsonObject item = null == targetItem ? sourceItem :
        append(sourceItem, targetItem, true);
    results.add(item);
  }
  target.clear();
  return target.addAll(results);
}

内容来源于网络，如有侵权，请联系作者删除！

JSONArray

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com