本文整理了Java中io.vertx.core.json.JsonArray.encodePrettily()
方法的一些代码示例,展示了JsonArray.encodePrettily()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JsonArray.encodePrettily()
方法的具体详情如下:
包路径:io.vertx.core.json.JsonArray
类名称:JsonArray
方法名:encodePrettily
[英]Encode the JSON array prettily as a string
[中]将JSON数组漂亮地编码为字符串
代码示例来源:origin: vert-x3/vertx-examples
private void handleListProducts(RoutingContext routingContext) {
JsonArray arr = new JsonArray();
products.forEach((k, v) -> arr.add(v));
routingContext.response().putHeader("content-type", "application/json").end(arr.encodePrettily());
}
代码示例来源:origin: vert-x3/vertx-examples
private void handleListProducts(RoutingContext routingContext) {
JsonArray arr = new JsonArray();
products.forEach((k, v) -> arr.add(v));
routingContext.response().putHeader("content-type", "application/json").end(arr.encodePrettily());
}
代码示例来源:origin: eclipse-vertx/vert.x
@Test
public void testEncodePrettily() throws Exception {
jsonArray.add("foo");
jsonArray.add(123);
jsonArray.add(1234l);
jsonArray.add(1.23f);
jsonArray.add(2.34d);
jsonArray.add(true);
byte[] bytes = TestUtils.randomByteArray(10);
jsonArray.add(bytes);
jsonArray.addNull();
jsonArray.add(new JsonObject().put("foo", "bar"));
jsonArray.add(new JsonArray().add("foo").add(123));
String strBytes = Base64.getEncoder().encodeToString(bytes);
String expected = "[ \"foo\", 123, 1234, 1.23, 2.34, true, \"" + strBytes + "\", null, {" + Utils.LINE_SEPARATOR +
" \"foo\" : \"bar\"" + Utils.LINE_SEPARATOR +
"}, [ \"foo\", 123 ] ]";
String json = jsonArray.encodePrettily();
assertEquals(expected, json);
}
代码示例来源:origin: io.vertx/vertx-core
@Test
public void testEncodePrettily() throws Exception {
jsonArray.add("foo");
jsonArray.add(123);
jsonArray.add(1234l);
jsonArray.add(1.23f);
jsonArray.add(2.34d);
jsonArray.add(true);
byte[] bytes = TestUtils.randomByteArray(10);
jsonArray.add(bytes);
jsonArray.addNull();
jsonArray.add(new JsonObject().put("foo", "bar"));
jsonArray.add(new JsonArray().add("foo").add(123));
String strBytes = Base64.getEncoder().encodeToString(bytes);
String expected = "[ \"foo\", 123, 1234, 1.23, 2.34, true, \"" + strBytes + "\", null, {" + Utils.LINE_SEPARATOR +
" \"foo\" : \"bar\"" + Utils.LINE_SEPARATOR +
"}, [ \"foo\", 123 ] ]";
String json = jsonArray.encodePrettily();
assertEquals(expected, json);
}
代码示例来源:origin: org.eclipse.hono/hono-server
.put(ARRAY_DEVICES, devices));
fs.writeFile(filename, Buffer.factory.buffer(tenants.encodePrettily()), writeAttempt -> {
if (writeAttempt.succeeded()) {
log.trace("successfully wrote {} device identities to file {}", idCount.get(), filename);
代码示例来源:origin: sczyh30/vertx-kue
private void apiJobTypes(RoutingContext context) {
kue.getAllTypes().setHandler(resultHandler(context, r -> {
context.response()
.putHeader("content-type", "application/json")
.end(new JsonArray(r).encodePrettily());
}));
}
代码示例来源:origin: org.eclipse.hono/hono-service-device-registry
vertx.fileSystem().writeFile(getConfig().getFilename(), Buffer.factory.buffer(tenants.encodePrettily()), writeHandler.completer());
return writeHandler.map(ok -> {
dirty = false;
代码示例来源:origin: sczyh30/vertx-kue
private void apiFetchLog(RoutingContext context) {
try {
long id = Long.parseLong(context.request().getParam("id"));
kue.getJobLog(id).setHandler(resultHandler(context, r -> {
context.response().putHeader("content-type", "application/json")
.end(r.encodePrettily());
}));
} catch (Exception e) {
badRequest(context, e);
}
}
代码示例来源:origin: org.eclipse.hono/hono-service-device-registry
vertx.fileSystem().writeFile(
getConfig().getFilename(),
Buffer.buffer(tenants.encodePrettily(), StandardCharsets.UTF_8.name()),
writeHandler.completer());
return writeHandler.map(ok -> {
代码示例来源:origin: eclipse/hono
vertx.fileSystem().writeFile(
getConfig().getFilename(),
Buffer.buffer(tenants.encodePrettily(), StandardCharsets.UTF_8.name()),
writeHandler.completer());
return writeHandler.map(ok -> {
代码示例来源:origin: io.vertx/vertx-codetrans
@CodeTranslate
public void encodePrettily() throws Exception {
JsonArray arr = new JsonArray().add("foo").add("bar");
JsonTest.o = arr.encodePrettily();
}
代码示例来源:origin: folio-org/okapi
xmlMsg.append(" Tenant parameters: ");
if (tenantParameters != null) {
xmlMsg.append(tenantParameters.encodePrettily());
代码示例来源:origin: sczyh30/vertx-kue
private void apiJobRange(RoutingContext context) {
try {
String order = context.request().getParam("order");
if (order == null || !isOrderValid(order))
order = "asc";
Long from = Long.parseLong(context.request().getParam("from"));
Long to = Long.parseLong(context.request().getParam("to"));
kue.jobRange(from, to, order)
.setHandler(resultHandler(context, r -> {
String result = new JsonArray(r).encodePrettily();
context.response()
.putHeader("content-type", "application/json")
.end(result);
}));
} catch (Exception e) {
e.printStackTrace();
badRequest(context, e);
}
}
代码示例来源:origin: eclipse/hono
Future<Void> saveToFile() {
if (!getConfig().isSaveToFile()) {
return Future.succeededFuture();
} else if (dirty) {
return checkFileExists(true).compose(s -> {
final JsonArray tenantsJson = new JsonArray();
tenants.values().stream().forEach(tenant -> {
tenantsJson.add(JsonObject.mapFrom(tenant));
});
final Future<Void> writeHandler = Future.future();
vertx.fileSystem().writeFile(getConfig().getFilename(),
Buffer.factory.buffer(tenantsJson.encodePrettily()), writeHandler.completer());
return writeHandler.map(ok -> {
dirty = false;
log.trace("successfully wrote {} tenants to file {}", tenantsJson.size(),
getConfig().getFilename());
return (Void) null;
}).otherwise(t -> {
log.warn("could not write tenants to file {}", getConfig().getFilename(), t);
return (Void) null;
});
});
} else {
log.trace("tenants registry does not need to be persisted");
return Future.succeededFuture();
}
}
代码示例来源:origin: sczyh30/vertx-kue
private void apiJobStateRange(RoutingContext context) {
try {
String order = context.request().getParam("order");
if (order == null || !isOrderValid(order))
order = "asc";
Long from = Long.parseLong(context.request().getParam("from"));
Long to = Long.parseLong(context.request().getParam("to"));
String state = context.request().getParam("state");
kue.jobRangeByState(state, from, to, order)
.setHandler(resultHandler(context, r -> {
String result = new JsonArray(r).encodePrettily();
context.response()
.putHeader("content-type", "application/json")
.end(result);
}));
} catch (Exception e) {
e.printStackTrace();
badRequest(context, e);
}
}
代码示例来源:origin: org.eclipse.hono/hono-service-device-registry
Future<Void> saveToFile() {
if (!getConfig().isSaveToFile()) {
return Future.succeededFuture();
} else if (dirty) {
return checkFileExists(true).compose(s -> {
final JsonArray tenantsJson = new JsonArray();
tenants.values().stream().forEach(tenant -> {
tenantsJson.add(JsonObject.mapFrom(tenant));
});
final Future<Void> writeHandler = Future.future();
vertx.fileSystem().writeFile(getConfig().getFilename(),
Buffer.factory.buffer(tenantsJson.encodePrettily()), writeHandler.completer());
return writeHandler.map(ok -> {
dirty = false;
log.trace("successfully wrote {} tenants to file {}", tenantsJson.size(),
getConfig().getFilename());
return (Void) null;
}).otherwise(t -> {
log.warn("could not write tenants to file {}", getConfig().getFilename(), t);
return (Void) null;
});
});
} else {
log.trace("tenants registry does not need to be persisted");
return Future.succeededFuture();
}
}
代码示例来源:origin: io.vertx/vertx-codetrans
@CodeTranslate
public void getJsonArray() {
JsonObject obj = JsonTest.object;
obj = JsonConverter.fromJsonObject(obj);
JsonTest.o = obj.getJsonArray("foo").encodePrettily();
}
代码示例来源:origin: sczyh30/vertx-kue
private void apiJobTypeRange(RoutingContext context) {
try {
String order = context.request().getParam("order");
if (order == null || !isOrderValid(order)) {
order = "asc";
}
Long from = Long.parseLong(context.request().getParam("from"));
Long to = Long.parseLong(context.request().getParam("to"));
String state = context.request().getParam("state");
String type = context.request().getParam("type");
kue.jobRangeByType(type, state, from, to, order)
.setHandler(resultHandler(context, r -> {
String result = new JsonArray(r).encodePrettily();
context.response()
.putHeader("content-type", "application/json")
.end(result);
}));
} catch (Exception e) {
e.printStackTrace();
badRequest(context, e);
}
}
代码示例来源:origin: vert-x3/vertx-service-discovery
@Before
public void setUp() {
services.clear();
vertx = Vertx.vertx();
AtomicBoolean done = new AtomicBoolean();
server = vertx.createHttpServer()
.requestHandler(request -> {
if (request.path().equals("/v1/catalog/services")) {
JsonObject result = new JsonObject();
services.forEach(object ->
result.put(object.getJsonObject("Service").getString("Service"), object.getJsonArray("tags", new JsonArray())));
request.response().putHeader("X-Consul-Index", "42").end(result.encodePrettily());
} else if (request.path().startsWith("/v1/health/service/")) {
String service = request.path().substring("/v1/health/service/".length());
JsonArray value = find(service);
if (value != null) {
request.response().putHeader("X-Consul-Index", "42").end(value.encodePrettily());
} else {
request.response().setStatusCode(404).end();
}
} else {
request.response().setStatusCode(404).end();
}
})
.listen(5601, ar -> done.set(ar.succeeded()));
await().untilAtomic(done, is(true));
}
代码示例来源:origin: io.vertx/vertx-service-discovery-bridge-consul
@Before
public void setUp() {
services.clear();
vertx = Vertx.vertx();
AtomicBoolean done = new AtomicBoolean();
server = vertx.createHttpServer()
.requestHandler(request -> {
if (request.path().equals("/v1/catalog/services")) {
JsonObject result = new JsonObject();
services.forEach(object ->
result.put(object.getJsonObject("Service").getString("Service"), object.getJsonArray("tags", new JsonArray())));
request.response().putHeader("X-Consul-Index", "42").end(result.encodePrettily());
} else if (request.path().startsWith("/v1/health/service/")) {
String service = request.path().substring("/v1/health/service/".length());
JsonArray value = find(service);
if (value != null) {
request.response().putHeader("X-Consul-Index", "42").end(value.encodePrettily());
} else {
request.response().setStatusCode(404).end();
}
} else {
request.response().setStatusCode(404).end();
}
})
.listen(5601, ar -> done.set(ar.succeeded()));
await().untilAtomic(done, is(true));
}
内容来源于网络,如有侵权,请联系作者删除!