org.jooq.lambda.Unchecked.supplier()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(7.3k)|赞(0)|评价(0)|浏览(197)

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

Unchecked.supplier介绍

[英]Wrap a CheckedSupplier in a Supplier.

Example: ``

  1. ResultSet rs = statement.executeQuery(); 
  2. Stream.generate(Unchecked.supplier(() -> rs.getObject(1)));

[中]将选中的供应商包装在供应商中。
示例：``

  1. ResultSet rs = statement.executeQuery(); 
  2. Stream.generate(Unchecked.supplier(() -> rs.getObject(1)));

代码示例

代码示例来源：origin: org.jooq/jool-java-8

  1. /**
  2.    * @see {@link Unchecked#supplier(CheckedSupplier, Consumer)}
  3.    */
  4.   static <T> Supplier<T> unchecked(CheckedSupplier<T> supplier, Consumer<Throwable> handler) {
  5.     return Unchecked.supplier(supplier, handler);
  6.   }
  7. }

代码示例来源：origin: org.jooq/jool

  1. /**
  2.  * Wrap a {@link CheckedSupplier} in a {@link Supplier}.
  3.  * <p>
  4.  * Example:
  5.  * <code><pre>
  6.  * ResultSet rs = statement.executeQuery();
  7.  * Stream.generate(Unchecked.supplier(() -> rs.getObject(1)));
  8.  * </pre></code>
  9.  */
  10. public static <T> Supplier<T> supplier(CheckedSupplier<T> supplier) {
  11.   return supplier(supplier, THROWABLE_TO_RUNTIME_EXCEPTION);
  12. }

代码示例来源：origin: org.jooq/jool

  1. /**
  2.  * Wrap a {@link CheckedSupplier} in a {@link Supplier}.
  3.  * <p>
  4.  * Example:
  5.  * <code><pre>
  6.  * ResultSet rs = statement.executeQuery();
  7.  * Stream.generate(Unchecked.supplier(() -> rs.getObject(1)));
  8.  * </pre></code>
  9.  */
  10. public static <T> Supplier<T> supplier(CheckedSupplier<T> supplier) {
  11.   return Unchecked.supplier(supplier, Unchecked.RETHROW_ALL);
  12. }

代码示例来源：origin: org.jooq/jool

  1. /**
  2.  * @see {@link Unchecked#supplier(CheckedSupplier)}
  3.  */
  4. static <T> Supplier<T> unchecked(CheckedSupplier<T> supplier) {
  5.   return Unchecked.supplier(supplier);
  6. }

代码示例来源：origin: org.jooq/jool

  1. /**
  2.    * @see {@link Unchecked#supplier(CheckedSupplier, Consumer)}
  3.    */
  4.   static <T> Supplier<T> unchecked(CheckedSupplier<T> supplier, Consumer<Throwable> handler) {
  5.     return Unchecked.supplier(supplier, handler);
  6.   }
  7. }

代码示例来源：origin: org.jooq/jool-java-8

  1. /**
  2.  * @see {@link Unchecked#supplier(CheckedSupplier)}
  3.  */
  4. static <T> Supplier<T> unchecked(CheckedSupplier<T> supplier) {
  5.   return Unchecked.supplier(supplier);
  6. }

代码示例来源：origin: org.jooq/jool-java-8

  1. /**
  2.  * Wrap a {@link CheckedSupplier} in a {@link Supplier}.
  3.  * <p>
  4.  * Example:
  5.  * <code><pre>
  6.  * ResultSet rs = statement.executeQuery();
  7.  * Stream.generate(Unchecked.supplier(() -> rs.getObject(1)));
  8.  * </pre></code>
  9.  */
  10. public static <T> Supplier<T> supplier(CheckedSupplier<T> supplier) {
  11.   return Unchecked.supplier(supplier, Unchecked.RETHROW_ALL);
  12. }

代码示例来源：origin: org.jooq/jool-java-8

  1. /**
  2.  * Wrap a {@link CheckedSupplier} in a {@link Supplier}.
  3.  * <p>
  4.  * Example:
  5.  * <code><pre>
  6.  * ResultSet rs = statement.executeQuery();
  7.  * Stream.generate(Unchecked.supplier(() -> rs.getObject(1)));
  8.  * </pre></code>
  9.  */
  10. public static <T> Supplier<T> supplier(CheckedSupplier<T> supplier) {
  11.   return supplier(supplier, THROWABLE_TO_RUNTIME_EXCEPTION);
  12. }

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

  1. private static void request(OkHttpClient client, String url) {
  2.   Request request = new Request.Builder()
  3.       .url(url)
  4.       .get()
  5.       .build();
  6.   Unchecked.supplier(() -> {
  7.     Response response = client.newCall(request).execute();
  8.     log.debug("{} - {}", response.code(), response.body().string());
  9.     return null;
  10.   }).get();
  11. }
  12. // {{end:request}}

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

  1. public List<User> listUsers() {
  2.   HttpUrl route = HttpUrl.parse(host + "/users");
  3.   Request request = new Request.Builder().url(route).get().build();
  4.   return Unchecked.supplier(() -> {
  5.     try (Response response = client.newCall(request).execute()) {
  6.       if (response.isSuccessful()) {
  7.         List<User> users = Json.serializer().fromInputStream(response.body().byteStream(), User.listTypeRef());
  8.         return users;
  9.       }
  10.       throw HttpClient.unknownException(response);
  11.     }
  12.   }).get();
  13. }
  14. // {{end:listUsers}}

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

  1. public void putInputStream(String bucket, String key, InputStream inputStream) {
  2.   // This can blow up on large files but that's ok for now.
  3.   byte[] bytes = Unchecked.supplier(() -> IOUtils.toByteArray(inputStream)).get();
  4.   putBytes(bucket, key, bytes);
  5. }

代码示例来源：origin: org.apereo.cas/cas-server-core-tickets-api

  1. /**
  2.  * Deserialize ticket.
  3.  *
  4.  * @param ticketContent the ticket id
  5.  * @param type          the type
  6.  * @return the ticket instance.
  7.  */
  8. @SneakyThrows
  9. public static Ticket deserializeTicket(final String ticketContent, final String type) {
  10.   if (StringUtils.isBlank(type)) {
  11.     throw new InvalidTicketException("Invalid ticket type [blank] specified");
  12.   }
  13.   val clazz = FunctionUtils.doIf(TICKET_TYPE_CACHE.containsKey(type),
  14.     () -> TICKET_TYPE_CACHE.get(type),
  15.     Unchecked.supplier(() -> {
  16.       val clz = Class.forName(type);
  17.       TICKET_TYPE_CACHE.put(type, clz);
  18.       return clz;
  19.     }))
  20.     .get();
  21.   return deserializeTicket(ticketContent, (Class) clazz);
  22. }

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

  1. public User createUser(User inputUser) {
  2.   HttpUrl route = HttpUrl.parse(host + "/users");
  3.   Request request = new Request.Builder()
  4.     .url(route)
  5.     .post(RequestBodies.jsonObj(inputUser))
  6.     .build();
  7.   return Unchecked.supplier(() -> {
  8.     try (Response response = client.newCall(request).execute()) {
  9.       if (response.code() == StatusCodes.CREATED) {
  10.         User user = Json.serializer().fromInputStream(response.body().byteStream(), User.typeRef());
  11.         return user;
  12.       }
  13.       if (response.code() == StatusCodes.BAD_REQUEST) {
  14.         return null;
  15.       }
  16.       throw HttpClient.unknownException(response);
  17.     }
  18.   }).get();
  19. }
  20. // {{end:createUser}}

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

  1. public User getUserByEmail(String email) {
  2.   HttpUrl route = HttpUrl.parse(host + "/users")
  3.               .newBuilder()
  4.               .addPathSegment(email)
  5.               .build();
  6.   Request request = new Request.Builder().url(route).get().build();
  7.   return Unchecked.supplier(() -> {
  8.     try (Response response = client.newCall(request).execute()) {
  9.       // The user exists
  10.       if (response.isSuccessful()) {
  11.         User user = Json.serializer().fromInputStream(response.body().byteStream(), User.typeRef());
  12.         return user;
  13.       }
  14.       /*
  15.        *  404 Not Found - Either return null or throw your own exception.
  16.        *  We prefer nulls.
  17.        */
  18.       if (response.code() == StatusCodes.NOT_FOUND) {
  19.         return null;
  20.       }
  21.       throw HttpClient.unknownException(response);
  22.     }
  23.   }).get();
  24. }
  25. // {{end:getUserByEmail}}

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

  1. public User updateUser(User inputUser) {
  2.   HttpUrl route = HttpUrl.parse(host + "/users");
  3.   Request request = new Request.Builder()
  4.       .url(route)
  5.       .put(RequestBodies.jsonObj(inputUser))
  6.       .build();
  7.   return Unchecked.supplier(() -> {
  8.     try (Response response = client.newCall(request).execute()) {
  9.       if (response.isSuccessful()) {
  10.         User user = Json.serializer().fromInputStream(response.body().byteStream(), User.typeRef());
  11.         return user;
  12.       }
  13.       if (response.code() == StatusCodes.NOT_FOUND) {
  14.         return null;
  15.       }
  16.       throw HttpClient.unknownException(response);
  17.     }
  18.   }).get();
  19. }
  20. // {{end:updateUser}}

代码示例来源：origin: org.apereo.cas/cas-server-core-services-api

  1. return Boolean.FALSE;
  2. return Unchecked.supplier(() -> {
  3.   for (var i = 1; i <= TOKEN_COUNT_DURATION; i++) {
  4.     p.nextToken();

代码示例来源：origin: org.apereo.cas/cas-server-support-wsfederation

  1. Unchecked.supplier(() -> {
  2.   LOGGER.debug("Encryption private key is an encrypted keypair");
  3.   val ckp = (PEMEncryptedKeyPair) privateKeyPemObject;
  4.   return converter.getKeyPair(ckp.decryptKeyPair(decProv));
  5. }),
  6. Unchecked.supplier(() -> {
  7.   LOGGER.debug("Extracting a keypair from the private key");
  8.   return converter.getKeyPair((PEMKeyPair) privateKeyPemObject);

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

  1. recMap.put("lda", Unchecked.supplier(() -> {
  2.   int k = 50;
  3.   double alpha = 1.0;
  4. recMap.put("fm-bpr", Unchecked.supplier(() -> {
  5. recMap.put("fm-rmse", Unchecked.supplier(() -> {

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

unchecked

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Unchecked类方法

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