Java BodyCodec类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中io.vertx.rxjava.ext.web.codec.BodyCodec类的典型用法代码示例。如果您正苦于以下问题：Java BodyCodec类的具体用法？Java BodyCodec怎么用？Java BodyCodec使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

BodyCodec类属于io.vertx.rxjava.ext.web.codec包，在下文中一共展示了BodyCodec类的12个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: get

import io.vertx.rxjava.ext.web.codec.BodyCodec; //导入依赖的package包/类
private void get(String uri, CacheItem<JsonObject> cache, Future<JsonObject> future, Retryable retryable) {
    client.get(HTTPS, ENDPOINT, uri).timeout(5000L).as(BodyCodec.jsonObject()).send(ar -> {
        if (ar.succeeded()) {
            HttpResponse<JsonObject> res = ar.result();
            if (res.statusCode() == OK) {
                future.complete(cache.set(res.body()));
            } else if (res.statusCode() == RATE_LIMIT) {
                retryable.retry(
                        () -> vertx.setTimer(getTimeTillReset(res), timer -> get(uri, cache, future, retryable)),
                        () -> future.fail("Too many retries."));
            } else {
                future.fail("TMDB API returned code: " + res.statusCode() +
                        "; message: " + res.statusMessage());
            }
        } else {
            retryable.retry(
                    () -> vertx.setTimer(DEFAULT_DELAY, timer -> get(uri, cache, future, retryable)),
                    () -> future.fail("Too many failures."));
        }
    });
}

开发者ID:kristenkotkas，项目名称:moviediary，代码行数:22，代码来源:TmdbServiceImpl.java

示例2: testGet

import io.vertx.rxjava.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void testGet() {
  int times = 5;
  waitFor(times);
  HttpServer server = vertx.createHttpServer(new HttpServerOptions().setPort(8080));
  server.requestStream().handler(req -> req.response().setChunked(true).end("some_content"));
  try {
    server.listen(ar -> {
      client = WebClient.wrap(vertx.createHttpClient(new HttpClientOptions()));
      Single<HttpResponse<Buffer>> single = client
        .get(8080, "localhost", "/the_uri")
        .as(BodyCodec.buffer())
        .rxSend();
      for (int i = 0; i < times; i++) {
        single.subscribe(resp -> {
          Buffer body = resp.body();
          assertEquals("some_content", body.toString("UTF-8"));
          complete();
        }, this::fail);
      }
    });
    await();
  } finally {
    server.close();
  }
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:27，代码来源:RxTest.java

示例3: testResponseBodyAsAsJsonMapped

import io.vertx.rxjava.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void testResponseBodyAsAsJsonMapped() throws Exception {
  JsonObject expected = new JsonObject().put("cheese", "Goat Cheese").put("wine", "Condrieu");
  HttpServer server = vertx.createHttpServer(new HttpServerOptions().setPort(8080));
  server.requestStream().handler(req -> req.response().end(expected.encode()));
  try {
    server.listen(ar -> {
      client = WebClient.wrap(vertx.createHttpClient(new HttpClientOptions()));
      Single<HttpResponse<WineAndCheese>> single = client
        .get(8080, "localhost", "/the_uri")
        .as(BodyCodec.json(WineAndCheese.class))
        .rxSend();
      single.subscribe(resp -> {
        assertEquals(200, resp.statusCode());
        assertEquals(new WineAndCheese().setCheese("Goat Cheese").setWine("Condrieu"), resp.body());
        testComplete();
      }, this::fail);
    });
    await();
  } finally {
    server.close();
  }
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:24，代码来源:RxTest.java

示例4: testErrorHandling

import io.vertx.rxjava.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void testErrorHandling() throws Exception {
  try {
    client = WebClient.wrap(vertx.createHttpClient(new HttpClientOptions()));
    Single<HttpResponse<WineAndCheese>> single = client
            .get(-1, "localhost", "/the_uri")
            .as(BodyCodec.json(WineAndCheese.class))
            .rxSend();
    single.subscribe(resp -> fail(), error -> {
      assertEquals(IllegalArgumentException.class, error.getClass());
      testComplete();
    });
    await();
  } catch (Throwable t) {
    fail();
  }
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:18，代码来源:RxTest.java

示例5: populate

import io.vertx.rxjava.ext.web.codec.BodyCodec; //导入依赖的package包/类
private static void populate(Vertx vertx, WebClient client) {
    JsonObject product1 = new JsonObject().put("name", "coffee").put("quantity", 2);
    JsonObject product2 = new JsonObject().put("name", "bacon").put("quantity", 1);
    JsonObject product3 = new JsonObject().put("name", "eggs").put("quantity", 3);

    client.post("/shopping")
        .rxSendJsonObject(product1)
        .flatMap(x -> client.post("/shopping").rxSendJsonObject(product2))
        .flatMap(x -> client.post("/shopping").rxSendJsonObject(product3))
        .flatMap(x -> client.get("/shopping").as(BodyCodec.jsonObject()).rxSend())
        .doAfterTerminate(vertx::close)
        .subscribe(resp -> dump("GET /shopping", resp), ShoppingBackendClient::dump);
}

开发者ID:cescoffier，项目名称:vertx-openshift-shopping-hol，代码行数:14，代码来源:ShoppingBackendClient.java

示例6: list

import io.vertx.rxjava.ext.web.codec.BodyCodec; //导入依赖的package包/类
private static void list(Vertx vertx, WebClient client) {
    client.get("/shopping")
        .as(BodyCodec.jsonObject())
        .rxSend()
        .doAfterTerminate(vertx::close)
        .subscribe(
            resp -> dump("GET /shopping", resp),
            ShoppingBackendClient::dump
        );
}

开发者ID:cescoffier，项目名称:vertx-openshift-shopping-hol，代码行数:11，代码来源:ShoppingBackendClient.java

示例7: add

import io.vertx.rxjava.ext.web.codec.BodyCodec; //导入依赖的package包/类
private static void add(Vertx vertx, WebClient client, Args args) {
    if (args.product == null  || args.product.isEmpty()) {
        System.out.println("Missing product name (-product)");
        return;
    }
    JsonObject body = new JsonObject().put("name", args.product).put("quantity", args.quantity);
    client.post("/shopping")
        .as(BodyCodec.jsonObject())
        .rxSendJsonObject(body)
        .doAfterTerminate(vertx::close)
        .subscribe(
            resp -> dump("GET /shopping", resp),
            ShoppingBackendClient::dump
        );
}

开发者ID:cescoffier，项目名称:vertx-openshift-shopping-hol，代码行数:16，代码来源:ShoppingBackendClient.java

示例8: remove

import io.vertx.rxjava.ext.web.codec.BodyCodec; //导入依赖的package包/类
private static void remove(Vertx vertx, WebClient client, Args args) {
    if (args.product == null  || args.product.isEmpty()) {
        System.out.println("Missing product name (-product)");
        return;
    }
    client.delete("/shopping/" + args.product)
        .as(BodyCodec.jsonObject())
        .rxSend()
        .doAfterTerminate(vertx::close)
        .subscribe(
            resp -> dump("DELETE /shopping/" + args.product, resp),
            ShoppingBackendClient::dump
        );
}

开发者ID:cescoffier，项目名称:vertx-openshift-shopping-hol，代码行数:15，代码来源:ShoppingBackendClient.java

示例9: moreComplex

import io.vertx.rxjava.ext.web.codec.BodyCodec; //导入依赖的package包/类
public void moreComplex(WebClient client) {
  Single<HttpResponse<JsonObject>> single = client
    .get(8080, "myserver.mycompany.com", "/some-uri")
    .putHeader("some-header", "header-value")
    .addQueryParam("some-param", "param value")
    .as(BodyCodec.jsonObject())
    .rxSend();
  single.subscribe(resp -> {
    System.out.println(resp.statusCode());
    System.out.println(resp.body());
  });
}

开发者ID:vert-x3，项目名称:vertx-web，代码行数:13，代码来源:RxWebClientExamples.java

示例10: playWithApi

import io.vertx.rxjava.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void playWithApi(TestContext context) {
	Async async = context.async();

	JsonObject page = new JsonObject()
			.put("name", "Sample")
			.put("markdown", "# A page");
	webClient
		.get("/wiki/api/token")
		.putHeader("login", "foo")
		.putHeader("password", "bar")
		.as(BodyCodec.string())
		.rxSendJsonObject(page)
		.map(r -> r.body())
		.flatMap(token -> {
			String jwtTokenHeaderValue = "Bearer " + token;
			return webClient.post("/wiki/api/pages")
					.putHeader("Authorization", jwtTokenHeaderValue)
					.as(BodyCodec.jsonObject())
					.rxSendJsonObject(page)
					.map(r -> r.body())
					.flatMap(response -> {
						context.assertTrue(response.getBoolean("success"));
						return webClient.get("/wiki/api/pages")
								.putHeader("Authorization", jwtTokenHeaderValue)
								.as(BodyCodec.jsonObject())
								.rxSendJsonObject(page)
								.map(r -> r.body());
					}).flatMap(response -> {
						context.assertTrue(response.getBoolean("success"));
						JsonArray array = response.getJsonArray("pages");
						context.assertEquals(1, array.size());
						context.assertNotNull(array.getJsonObject(0).getInteger("id"));
						return webClient.put("/wiki/api/pages/0")
								.putHeader("Authorization", jwtTokenHeaderValue)
								.as(BodyCodec.jsonObject())
								.rxSendJsonObject(new JsonObject()
										.put("id", 0)
										.put("markdown", "Oh Yeah!"))
								.map(r -> r.body());
					}).flatMap(response -> {
						context.assertTrue(response.getBoolean("success"));
						return webClient.delete("/wiki/api/pages/0")
								.putHeader("Authorization", jwtTokenHeaderValue)
								.as(BodyCodec.jsonObject())
								.rxSendJsonObject(new JsonObject()
										.put("id", 0)
										.put("markdown", "Oh Yeah!"))
								.map(r -> r.body());
				});
	}).doOnError(x -> context.fail(x)).subscribe(response -> {
		context.assertTrue(response.getBoolean("success"));
		async.complete();
	});
}

开发者ID:FroMage，项目名称:redpipe，代码行数:56，代码来源:ApiTest.java

示例11: playWithApi

import io.vertx.rxjava.ext.web.codec.BodyCodec; //导入依赖的package包/类
@Test
public void playWithApi(TestContext context) {
	Async async = context.async();

	JsonObject page = new JsonObject()
			.put("name", "Sample")
			.put("markdown", "# A page");
	
	webClient
		.get("/wiki/api/token")
		.putHeader("login", "foo")
		.putHeader("password", "bar")
		.as(BodyCodec.string())
		.rxSendJsonObject(page)
		.map(r -> r.body())
		.flatMap(token -> {
			String jwtTokenHeaderValue = "Bearer " + token;
			return webClient.post("/wiki/api/pages")
					.putHeader("Authorization", jwtTokenHeaderValue)
					.as(BodyCodec.jsonObject())
					.rxSendJsonObject(page)
					.map(r -> r.body())
					.flatMap(response -> {
						context.assertTrue(response.getBoolean("success"));
						return webClient.get("/wiki/api/pages")
								.putHeader("Authorization", jwtTokenHeaderValue)
								.as(BodyCodec.jsonObject())
								.rxSendJsonObject(page)
								.map(r -> r.body());
					}).flatMap(response -> {
						context.assertTrue(response.getBoolean("success"));
						JsonArray array = response.getJsonArray("pages");
						context.assertEquals(1, array.size());
						context.assertNotNull(array.getJsonObject(0).getInteger("id"));
						return webClient.put("/wiki/api/pages/0")
								.putHeader("Authorization", jwtTokenHeaderValue)
								.as(BodyCodec.jsonObject())
								.rxSendJsonObject(new JsonObject()
										.put("id", 0)
										.put("markdown", "Oh Yeah!"))
								.map(r -> r.body());
					}).flatMap(response -> {
						context.assertTrue(response.getBoolean("success"));
						return webClient.delete("/wiki/api/pages/0")
								.putHeader("Authorization", jwtTokenHeaderValue)
								.as(BodyCodec.jsonObject())
								.rxSendJsonObject(new JsonObject()
										.put("id", 0)
										.put("markdown", "Oh Yeah!"))
								.map(r -> r.body());
				});
	}).doOnError(x -> context.fail(x)).subscribe(response -> {
		context.assertTrue(response.getBoolean("success"));
		async.complete();
	});
}

开发者ID:FroMage，项目名称:redpipe，代码行数:57，代码来源:ApiTest.java

示例12: main

import io.vertx.rxjava.ext.web.codec.BodyCodec; //导入依赖的package包/类
public static void main(String[] args) {

    Vertx vertx = Vertx.vertx();
    Router router = buildRouter();
    EventBus eventBus = buildEventBus();

    Flow flow = Flow.flow(vertx);

    // Simple
    flow.withDiscovery(null).route(router.get("/foo/bar"), httpFlow -> {
      httpFlow.rxHttpRequest(new JsonObject(), HttpMethod.GET, "/")
        .subscribe(req -> {
        req.addQueryParam("foo", httpFlow.pathParam("foo")).rxSend().subscribe(resp -> {

        });
      });
    });

    // Simple with fallback
    flow.withDiscovery(null).route(router.get("/foo/bar"), httpFlow -> {
      httpFlow.rxHttpRequest(new JsonObject(), HttpMethod.GET, "/")
        .flatMap(req -> req.addQueryParam("foo", httpFlow.pathParam("foo")).as(BodyCodec.string()).rxSend())
        .map(HttpResponse::body)
        .onErrorReturn(err -> "use the fallback").subscribe(s -> {
        System.out.println("result is " + s);
      });
    });

    // Nested
    flow.route(router.get("/foo/bar"), httpFlow -> {
      httpFlow.rxHttpRequest(new JsonObject(), HttpMethod.GET, "/").subscribe(req -> {
        req.addQueryParam("foo", "bar").rxSend().subscribe(resp -> {
          //
        }, err -> {
          httpFlow.sendMessage(new JsonObject(), "failed");
        });
      });
    });

    // Parallel
    flow.from(eventBus.<String>consumer("foobar"), messageFlow -> {
      messageFlow.rxHttpRequest(new JsonObject(), HttpMethod.GET, "/").subscribe(req -> {
        req.addQueryParam("foo", messageFlow.body()).rxSend().subscribe(resp -> {
          //
        });
      });
      messageFlow.sendMessage(new JsonObject(), messageFlow.body());
    });
  }

开发者ID:vietj，项目名称:vertx-service-flow，代码行数:50，代码来源:RxExample.java

注：本文中的io.vertx.rxjava.ext.web.codec.BodyCodec类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java Hashtag类代码示例发布时间：2022-05-23

Java DefaultAuthenticator类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18924|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9906|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8298|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8657|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8591|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9598|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8582|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7971|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8590|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7510|2022-11-06

客服电话

电子邮件

Java BodyCodec类代码示例

示例1: get

示例2: testGet

示例3: testResponseBodyAsAsJsonMapped

示例4: testErrorHandling

示例5: populate

示例6: list

示例7: add

示例8: remove

示例9: moreComplex

示例10: playWithApi

示例11: playWithApi

示例12: main

请发表评论

全部评论

上一篇：

下一篇：

chasinginfinity/ml-from-scratch: Machine

mkyong/spring3-mvc-maven-annotation-hell

CVE-2022-23003

床的笔顺,关于床的笔画,体会床的部首

zendesk/android-floating-action-button:

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053