com.linecorp.centraldogma.internal.Util.unsafeCast()方法的使用及代码示例

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

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

Util.unsafeCast介绍

[英]Casts an object unsafely. Used when you want to suppress the unchecked type warnings.
[中]不安全地投射对象。要抑制未选中的类型警告时使用。

代码示例

代码示例来源：origin: line/centraldogma

  1. protected final <T extends SessionManager> T delegate() {
  2.   return Util.unsafeCast(delegate);
  3. }

代码示例来源：origin: line/centraldogma

  1. protected final <T extends CommandExecutor> T delegate() {
  2.   return Util.unsafeCast(delegate);
  3. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

  1. /**
  2.  * Returns a raw session instance which is casted to {@code T} type.
  3.  *
  4.  * @throws NullPointerException if the {@code rawSession} is {@code null}
  5.  * @throws ClassCastException if the {@code rawSession} cannot be casted to {@code T}
  6.  */
  7. <T> T castRawSession() {
  8.   return Util.unsafeCast(requireNonNull(rawSession, "rawSession"));
  9. }

代码示例来源：origin: line/centraldogma

  1. /**
  2.  * Returns a raw session instance which is casted to {@code T} type.
  3.  *
  4.  * @throws NullPointerException if the {@code rawSession} is {@code null}
  5.  * @throws ClassCastException if the {@code rawSession} cannot be casted to {@code T}
  6.  */
  7. <T> T castRawSession() {
  8.   return Util.unsafeCast(requireNonNull(rawSession, "rawSession"));
  9. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-client

  1. /**
  2.  * Creates a new instance.
  3.  */
  4. public <U> FileWatcher(CentralDogma client, ScheduledExecutorService executor,
  5.         String projectName, String repositoryName,
  6.         Query<U> query, Function<? super U, ? extends T> function) {
  7.   super(client, executor, projectName, repositoryName, requireNonNull(query, "query").path());
  8.   this.query = unsafeCast(query);
  9.   this.function = unsafeCast(requireNonNull(function, "function"));
  10. }

代码示例来源：origin: line/centraldogma

  1. /**
  2.  * Creates a new instance.
  3.  */
  4. public <U> FileWatcher(CentralDogma client, ScheduledExecutorService executor,
  5.         String projectName, String repositoryName,
  6.         Query<U> query, Function<? super U, ? extends T> function) {
  7.   super(client, executor, projectName, repositoryName, requireNonNull(query, "query").path());
  8.   this.query = unsafeCast(query);
  9.   this.function = unsafeCast(requireNonNull(function, "function"));
  10. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-client-shaded

  1. /**
  2.  * Creates a new instance.
  3.  */
  4. public <U> FileWatcher(CentralDogma client, ScheduledExecutorService executor,
  5.         String projectName, String repositoryName,
  6.         Query<U> query, Function<? super U, ? extends T> function) {
  7.   super(client, executor, projectName, repositoryName, requireNonNull(query, "query").path());
  8.   this.query = unsafeCast(query);
  9.   this.function = unsafeCast(requireNonNull(function, "function"));
  10. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

  1. CacheableQueryCall(Repository repo, Revision revision, Query<?> query) {
  2.   super(repo);
  3.   this.revision = requireNonNull(revision, "revision");
  4.   this.query = unsafeCast(requireNonNull(query, "query"));
  5.   hashCode = Objects.hash(revision, query) * 31 + System.identityHashCode(repo);
  6.   assert !revision.isRelative();
  7. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

  1. static <T> CompletableFuture<Entry<T>> watch(Repository repo, Revision lastKnownRev, Query<T> query) {
  2.   requireNonNull(repo, "repo");
  3.   requireNonNull(lastKnownRev, "lastKnownRev");
  4.   requireNonNull(query, "query");
  5.   final Query<Object> castQuery = unsafeCast(query);
  6.   final CompletableFuture<Entry<Object>> parentFuture = new CompletableFuture<>();
  7.   repo.getOrNull(lastKnownRev, castQuery)
  8.     .thenAccept(oldResult -> watch(repo, castQuery, lastKnownRev, oldResult, parentFuture))
  9.     .exceptionally(voidFunction(parentFuture::completeExceptionally));
  10.   return unsafeCast(parentFuture);
  11. }

代码示例来源：origin: line/centraldogma

  1. static <T> CompletableFuture<Entry<T>> watch(Repository repo, Revision lastKnownRev, Query<T> query) {
  2.   requireNonNull(repo, "repo");
  3.   requireNonNull(lastKnownRev, "lastKnownRev");
  4.   requireNonNull(query, "query");
  5.   final Query<Object> castQuery = unsafeCast(query);
  6.   final CompletableFuture<Entry<Object>> parentFuture = new CompletableFuture<>();
  7.   repo.getOrNull(lastKnownRev, castQuery)
  8.     .thenAccept(oldResult -> watch(repo, castQuery, lastKnownRev, oldResult, parentFuture))
  9.     .exceptionally(voidFunction(parentFuture::completeExceptionally));
  10.   return unsafeCast(parentFuture);
  11. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

  1. static <T> CompletableFuture<Entry<T>> watch(Repository repo, Revision lastKnownRev, Query<T> query) {
  2.   requireNonNull(repo, "repo");
  3.   requireNonNull(lastKnownRev, "lastKnownRev");
  4.   requireNonNull(query, "query");
  5.   final Query<Object> castQuery = unsafeCast(query);
  6.   final CompletableFuture<Entry<Object>> parentFuture = new CompletableFuture<>();
  7.   repo.getOrNull(lastKnownRev, castQuery)
  8.     .thenAccept(oldResult -> watch(repo, castQuery, lastKnownRev, oldResult, parentFuture))
  9.     .exceptionally(voidFunction(parentFuture::completeExceptionally));
  10.   return unsafeCast(parentFuture);
  11. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

  1. @Override
  2. public CompletableFuture<Map<String, Entry<?>>> find(Revision revision, String pathPattern,
  3.                            Map<FindOption<?>, ?> options) {
  4.   requireNonNull(revision, "revision");
  5.   requireNonNull(pathPattern, "pathPattern");
  6.   requireNonNull(options, "options");
  7.   final CompletableFuture<Object> future = normalizeAndCompose(
  8.       revision,
  9.       rev -> cache.get(new CacheableFindCall(repo, rev, pathPattern, options)));
  10.   return unsafeCast(future);
  11. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

  1. @Override
  2. public <T> CompletableFuture<Entry<T>> getOrNull(Revision revision, Query<T> query) {
  3.   requireNonNull(revision, "revision");
  4.   requireNonNull(query, "query");
  5.   final CompletableFuture<Object> future = normalizeAndCompose(
  6.       revision,
  7.       rev -> cache.get(new CacheableQueryCall(repo, rev, query))
  8.             .thenApply(result -> result != CacheableQueryCall.EMPTY ? result : null));
  9.   return unsafeCast(future);
  10. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

  1. @Override
  2. public CompletableFuture<Map<String, Entry<?>>> find(Revision revision, String pathPattern,
  3.                            Map<FindOption<?>, ?> options) {
  4.   requireNonNull(revision, "revision");
  5.   requireNonNull(pathPattern, "pathPattern");
  6.   requireNonNull(options, "options");
  7.   final Revision normalizedRevision;
  8.   try {
  9.     normalizedRevision = normalizeNow(revision);
  10.   } catch (Exception e) {
  11.     return CompletableFutures.exceptionallyCompletedFuture(e);
  12.   }
  13.   return unsafeCast(cache.get(new CacheableFindCall(repo, normalizedRevision, pathPattern, options)));
  14. }

代码示例来源：origin: line/centraldogma

  1. @Override
  2. public CompletableFuture<Map<String, Change<?>>> diff(Revision from, Revision to, String pathPattern) {
  3.   requireNonNull(from, "from");
  4.   requireNonNull(to, "to");
  5.   requireNonNull(pathPattern, "pathPattern");
  6.   final RevisionRange range;
  7.   try {
  8.     range = normalizeNow(from, to).toAscending();
  9.   } catch (Exception e) {
  10.     return CompletableFutures.exceptionallyCompletedFuture(e);
  11.   }
  12.   return unsafeCast(cache.get(new CacheableMultiDiffCall(repo, range.from(), range.to(), pathPattern)));
  13. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

  1. @Override
  2. public CompletableFuture<Change<?>> diff(Revision from, Revision to, Query<?> query) {
  3.   requireNonNull(from, "from");
  4.   requireNonNull(to, "to");
  5.   requireNonNull(query, "query");
  6.   final RevisionRange range;
  7.   try {
  8.     range = normalizeNow(from, to).toAscending();
  9.   } catch (Exception e) {
  10.     return CompletableFutures.exceptionallyCompletedFuture(e);
  11.   }
  12.   return unsafeCast(cache.get(new CacheableSingleDiffCall(repo, range.from(), range.to(), query)));
  13. }

代码示例来源：origin: line/centraldogma

  1. @Override
  2. public CompletableFuture<Change<?>> diff(Revision from, Revision to, Query<?> query) {
  3.   requireNonNull(from, "from");
  4.   requireNonNull(to, "to");
  5.   requireNonNull(query, "query");
  6.   final RevisionRange range;
  7.   try {
  8.     range = normalizeNow(from, to).toAscending();
  9.   } catch (Exception e) {
  10.     return CompletableFutures.exceptionallyCompletedFuture(e);
  11.   }
  12.   return unsafeCast(cache.get(new CacheableSingleDiffCall(repo, range.from(), range.to(), query)));
  13. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

  1. @Override
  2. public CompletableFuture<Map<String, Change<?>>> diff(Revision from, Revision to, String pathPattern) {
  3.   requireNonNull(from, "from");
  4.   requireNonNull(to, "to");
  5.   requireNonNull(pathPattern, "pathPattern");
  6.   final RevisionRange range;
  7.   try {
  8.     range = normalizeNow(from, to).toAscending();
  9.   } catch (Exception e) {
  10.     return CompletableFutures.exceptionallyCompletedFuture(e);
  11.   }
  12.   return unsafeCast(cache.get(new CacheableMultiDiffCall(repo, range.from(), range.to(), pathPattern)));
  13. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

  1. @Override
  2. public CompletableFuture<Change<?>> diff(Revision from, Revision to, Query<?> query) {
  3.   requireNonNull(from, "from");
  4.   requireNonNull(to, "to");
  5.   requireNonNull(query, "query");
  6.   final RevisionRange range;
  7.   try {
  8.     range = normalizeNow(from, to).toAscending();
  9.   } catch (Exception e) {
  10.     return CompletableFutures.exceptionallyCompletedFuture(e);
  11.   }
  12.   return unsafeCast(cache.get(new CacheableSingleDiffCall(repo, range.from(), range.to(), query)));
  13. }

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

  1. @Override
  2. public CompletableFuture<Map<String, Change<?>>> diff(Revision from, Revision to, String pathPattern) {
  3.   requireNonNull(from, "from");
  4.   requireNonNull(to, "to");
  5.   requireNonNull(pathPattern, "pathPattern");
  6.   final RevisionRange range;
  7.   try {
  8.     range = normalizeNow(from, to).toAscending();
  9.   } catch (Exception e) {
  10.     return CompletableFutures.exceptionallyCompletedFuture(e);
  11.   }
  12.   return unsafeCast(cache.get(new CacheableMultiDiffCall(repo, range.from(), range.to(), pathPattern)));
  13. }

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

Util

相关文章

    查看更多

    热门标签

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

    最新文章

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