org.jooq.lambda.Unchecked类的使用及代码示例

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

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

Unchecked介绍

[英]Improved interoperability between checked exceptions and Java 8.

Checked exceptions are one of Java's biggest flaws. Due to backwards-compatibility, we're inheriting all the checked exception trouble back from JDK 1.0. This becomes even more obvious when using lambda expressions, most of which are not allowed to throw checked exceptions.

This library tries to ease some pain and wraps / unwraps a variety of API elements from the JDK 8 to improve interoperability with checked exceptions.
[中]改进了检查异常和Java 8之间的互操作性。
检查异常是Java最大的缺陷之一。由于向后兼容，我们从JDK1.0继承了所有检查异常问题。当使用lambda表达式时，这一点变得更加明显，其中大多数表达式都不允许抛出选中的异常。
这个库试图减轻一些痛苦，并从JDK 8中包装/解包各种API元素，以提高与已检查异常的互操作性。

代码示例

代码示例来源：origin: apache/storm

dataAndExpected.add(new Tuple3<>(13, 12, null));
dataAndExpected.forEach(Unchecked.consumer(data -> {
  Map<String, Object> result = handler.substringSearch(file, pattern, data.v1());
  assertEquals(data.v3(), result.get("nextByteOffset"));

代码示例来源：origin: apache/storm

/**
 * Delete the oldest files in each overloaded worker log dir.
 */
@VisibleForTesting
List<DeletionMeta> perWorkerDirCleanup(long size) {
  return workerLogs.getAllWorkerDirs().stream()
      .map(Unchecked.function(dir ->
          directoryCleaner.deleteOldestWhileTooLarge(Collections.singletonList(dir), size, true, null)))
      .collect(toList());
}

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

/**
 * Wrap a {@link CheckedSupplier} in a {@link Supplier}.
 * <p>
 * Example:
 * <code><pre>
 * ResultSet rs = statement.executeQuery();
 * Stream.generate(Unchecked.supplier(() -> rs.getObject(1)));
 * </pre></code>
 */
public static <T> Supplier<T> supplier(CheckedSupplier<T> supplier) {
  return supplier(supplier, THROWABLE_TO_RUNTIME_EXCEPTION);
}

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

@Override
protected void configure(final HttpSecurity http) throws Exception {
  http.csrf().disable()
    .headers().disable()
    .logout()
    .disable()
    .requiresChannel()
    .requestMatchers(r -> r.getHeader("X-Forwarded-Proto") != null)
    .requiresSecure();
  val requests = http.authorizeRequests();
  configureEndpointAccessToDenyUndefined(http, requests);
  configureEndpointAccessForStaticResources(requests);
  val endpoints = casProperties.getMonitor().getEndpoints().getEndpoint();
  endpoints.forEach(Unchecked.biConsumer((k, v) -> {
    val endpoint = EndpointRequest.to(k);
    v.getAccess().forEach(Unchecked.consumer(access -> configureEndpointAccess(http, requests, access, v, endpoint)));
  }));
}

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

recMap.put("lda", Unchecked.supplier(() -> {
  int k = 50;
  double alpha = 1.0;
recMap.put("fm-bpr", Unchecked.supplier(() -> {
recMap.put("fm-rmse", Unchecked.supplier(() -> {
RecommenderRunner<Long, Long> runner = new FastFilterRecommenderRunner<>(userIndex, itemIndex, targetUsers.stream(), filter, maxLength);
recMap.forEach(Unchecked.biConsumer((name, recommender) -> {
  System.out.println("Running " + name);
  try (RecommendationFormat.Writer<Long, Long> writer = format.getWriter(name)) {

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

/**
   * @see {@link Unchecked#runnable(CheckedRunnable, Consumer)}
   */
  static Runnable unchecked(CheckedRunnable runnable, Consumer<Throwable> handler) {
    return Unchecked.runnable(runnable, handler);
  }
}

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

/**
   * @see {@link Unchecked#biConsumer(CheckedBiConsumer, Consumer)}
   */
  static <T, U> BiConsumer<T, U> unchecked(CheckedBiConsumer<T, U> consumer, Consumer<Throwable> handler) {
    return Unchecked.biConsumer(consumer, handler);
  }
}

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

/**
 * Saves a PreferenceData instance in two files for user and item preferences, respectively. The format of the user preferences stream consists on one list per line, starting with the identifier of the user followed by the identifier-rating pairs of the items related to that. The item preferences stream follows the same format by swapping the roles of users and items.
 *
 * @param prefData preferences
 * @param uo stream of user preferences
 * @param io stream of user preferences
 */
public void write(FastPreferenceData<?, ?> prefData, OutputStream uo, OutputStream io) {
  BiConsumer<FastPreferenceData<?, ?>, OutputStream> saver = Unchecked.biConsumer((prefs, os) -> {
    try (BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(os))) {
      prefs.getUidxWithPreferences().forEach(Unchecked.intConsumer(uidx -> {
        String a = prefs.getUidxPreferences(uidx)
            .sorted((p1, p2) -> Integer.compare(p1.v1, p2.v1))
            .map(p -> p.v1 + "\t" + (int) p.v2)
            .collect(joining("\t"));
        writer.write(uidx + "\t" + a);
        writer.newLine();
      }));
    }
  });
  saver.accept(prefData, uo);
  saver.accept(new TransposedPreferenceData<>(prefData), io);
}

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

/**
 * Wrap a {@link org.jooq.lambda.fi.util.function.CheckedBooleanSupplier} in a {@link BooleanSupplier}.
 * <p>
 * Example:
 * <code><pre>
 * ResultSet rs = statement.executeQuery();
 * Stream.generate(Unchecked.booleanSupplier(() -> rs.getBoolean(1)));
 * </pre></code>
 */
public static BooleanSupplier booleanSupplier(CheckedBooleanSupplier supplier) {
  return Unchecked.booleanSupplier(supplier, Unchecked.RETHROW_ALL);
}

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

/**
 * Wrap a {@link CheckedSupplier} in a {@link Supplier}.
 * <p>
 * Example:
 * <code><pre>
 * ResultSet rs = statement.executeQuery();
 * Stream.generate(Unchecked.supplier(() -> rs.getObject(1)));
 * </pre></code>
 */
public static <T> Supplier<T> supplier(CheckedSupplier<T> supplier) {
  return Unchecked.supplier(supplier, Unchecked.RETHROW_ALL);
}

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

rerankersMap.forEach(Unchecked.biConsumer((name, rerankerSupplier) -> {
  System.out.println("Running " + name);
  String recOut = String.format("%s_%s", recIn, name);
    format.getReader(recIn).readAll()
        .map(rec -> reranker.rerankRecommendation(rec, cutoff))
        .forEach(Unchecked.consumer(writer::write));

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

/**
 * @see {@link Unchecked#runnable(CheckedRunnable)}
 */
static Runnable unchecked(CheckedRunnable runnable) {
  return Unchecked.runnable(runnable);
}

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

/**
 * @see {@link Unchecked#biConsumer(CheckedBiConsumer)}
 */
static <T, U> BiConsumer<T, U> unchecked(CheckedBiConsumer<T, U> consumer) {
  return Unchecked.biConsumer(consumer);
}

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

/**
 * Saves a PreferenceData instance in two files for user and item preferences, respectively. The format of the user preferences stream consists on one list per line, starting with the identifier of the user followed by the identifiers of the items related to that. The item preferences stream follows the same format by swapping the roles of users and items.
 *
 * @param prefData preferences
 * @param uo stream of user preferences
 * @param io stream of user preferences
 */
public void write(FastPreferenceData<?, ?> prefData, OutputStream uo, OutputStream io) {
  BiConsumer<FastPreferenceData<?, ?>, OutputStream> saver = Unchecked.biConsumer((prefs, os) -> {
    try (BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(os))) {
      prefs.getUidxWithPreferences().forEach(Unchecked.intConsumer(uidx -> {
        String a = prefs.getUidxPreferences(uidx)
            .mapToInt(IdxPref::v1)
            .sorted()
            .mapToObj(Integer::toString)
            .collect(joining("\t"));
        writer.write(uidx + "\t" + a);
        writer.newLine();
      }));
    }
  });
  saver.accept(prefData, uo);
  saver.accept(new TransposedPreferenceData<>(prefData), io);
}

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

/**
 * @see {@link Unchecked#booleanSupplier(CheckedBooleanSupplier)}
 */
static BooleanSupplier unchecked(CheckedBooleanSupplier supplier) {
  return Unchecked.booleanSupplier(supplier);
}

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

/**
   * @see {@link Unchecked#consumer(CheckedConsumer, Consumer)}
   */
  static <T> Consumer<T> unchecked(CheckedConsumer<T> consumer, Consumer<Throwable> handler) {
    return Unchecked.consumer(consumer, handler);
  }
}

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

/**
 * @see {@link Unchecked#supplier(CheckedSupplier)}
 */
static <T> Supplier<T> unchecked(CheckedSupplier<T> supplier) {
  return Unchecked.supplier(supplier);
}

代码示例来源：origin: hs-web/hsweb-framework

@Override
  public void list(String path, Consumer<FTPFile> consumer) {
    doExecute(Unchecked.function(client -> {
      Arrays.stream(client.listFiles(path)).forEach(consumer);
      return null;
    }));
  }
}

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

/**
   * @see {@link Unchecked#runnable(CheckedRunnable, Consumer)}
   */
  static Runnable unchecked(CheckedRunnable runnable, Consumer<Throwable> handler) {
    return Unchecked.runnable(runnable, handler);
  }
}

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

/**
 * @see {@link Unchecked#biConsumer(CheckedBiConsumer)}
 */
static <T, U> BiConsumer<T, U> unchecked(CheckedBiConsumer<T, U> consumer) {
  return Unchecked.biConsumer(consumer);
}

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

unchecked

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Unchecked类方法

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