scala.util.Try.failed()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(7.8k)|赞(0)|评价(0)|浏览(424)

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

Try.failed介绍

暂无

代码示例

代码示例来源：origin: vert-x3/vertx-mysql-postgresql-client

  1. @Override
  2.  public Void apply(Try<T> v1) {
  3.   if (v1.isSuccess()) {
  4.    fut.complete();
  5.   } else {
  6.    fut.fail(v1.failed().get());
  7.   }
  8.   return null;
  9.  }
  10. }, ec);

代码示例来源：origin: vert-x3/vertx-mysql-postgresql-client

  1. @Override
  2.  public Void apply(Try<V> v1) {
  3.   if (v1.isSuccess()) {
  4.    code.handle(Future.succeededFuture(v1.get()));
  5.   } else {
  6.    code.handle(Future.failedFuture(v1.failed().get()));
  7.   }
  8.   return null;
  9.  }
  10. };

代码示例来源：origin: vert-x3/vertx-mysql-postgresql-client

  1. @Override
  2.  public Void apply(Try<T> v1) {
  3.   if (v1.isSuccess()) {
  4.    fut.complete(v1.get());
  5.   } else {
  6.    fut.fail(v1.failed().get());
  7.   }
  8.   return null;
  9.  }
  10. }, ec);

代码示例来源：origin: org.eclipse.ditto/ditto-services-connectivity-mapping

  1. private MessageMapper createInstanceFor(final String className)
  2.     throws ClassNotFoundException, InstantiationException {
  3.   final ClassTag<MessageMapper> tag = scala.reflect.ClassTag$.MODULE$.apply(MessageMapper.class);
  4.   final List<Tuple2<Class<?>, Object>> constructorArgs = new ArrayList<>();
  5.   final Try<MessageMapper> mapperTry =
  6.       dynamicAccess.createInstanceFor(className, JavaConversions.asScalaBuffer(constructorArgs).toList(),
  7.           tag);
  8.   if (mapperTry.isFailure()) {
  9.     final Throwable error = mapperTry.failed().get();
  10.     if (error.getClass().isAssignableFrom(ClassNotFoundException.class)) {
  11.       throw (ClassNotFoundException) error;
  12.     } else if (error.getClass().isAssignableFrom(InstantiationException.class)) {
  13.       throw (InstantiationException) error;
  14.     } else if (error.getClass().isAssignableFrom(ClassCastException.class)) {
  15.       throw (ClassCastException) error;
  16.     } else {
  17.       throw new IllegalStateException("There was an unknown error when trying to creating instance for '"
  18.           + className + "'", error);
  19.     }
  20.   }
  21.   return mapperTry.get();
  22. }

代码示例来源：origin: eclipse/ditto

  1. private MessageMapper createInstanceFor(final String className)
  2.     throws ClassNotFoundException, InstantiationException {
  3.   final ClassTag<MessageMapper> tag = scala.reflect.ClassTag$.MODULE$.apply(MessageMapper.class);
  4.   final List<Tuple2<Class<?>, Object>> constructorArgs = new ArrayList<>();
  5.   final Try<MessageMapper> mapperTry =
  6.       dynamicAccess.createInstanceFor(className, JavaConversions.asScalaBuffer(constructorArgs).toList(),
  7.           tag);
  8.   if (mapperTry.isFailure()) {
  9.     final Throwable error = mapperTry.failed().get();
  10.     if (error.getClass().isAssignableFrom(ClassNotFoundException.class)) {
  11.       throw (ClassNotFoundException) error;
  12.     } else if (error.getClass().isAssignableFrom(InstantiationException.class)) {
  13.       throw (InstantiationException) error;
  14.     } else if (error.getClass().isAssignableFrom(ClassCastException.class)) {
  15.       throw (ClassCastException) error;
  16.     } else {
  17.       throw new IllegalStateException("There was an unknown error when trying to creating instance for '"
  18.           + className + "'", error);
  19.     }
  20.   }
  21.   return mapperTry.get();
  22. }

代码示例来源：origin: org.talend.components/processing-runtime

  1. private List<Object> getInputFields(IndexedRecord inputRecord, String columnName) {
  2.   // Adapt non-avpath syntax to avpath.
  3.   // TODO: This should probably not be automatic, use the actual syntax.
  4.   if (!columnName.startsWith("."))
  5.     columnName = "." + columnName;
  6.   Try<scala.collection.immutable.List<Evaluator.Ctx>> result = wandou.avpath.package$.MODULE$.select(inputRecord,
  7.       columnName);
  8.   List<Object> values = new ArrayList<Object>();
  9.   if (result.isSuccess()) {
  10.     for (Evaluator.Ctx ctx : JavaConversions.asJavaCollection(result.get())) {
  11.       values.add(ctx.value());
  12.     }
  13.   } else {
  14.     // Evaluating the expression failed, and we can handle the exception.
  15.     Throwable t = result.failed().get();
  16.     throw ProcessingErrorCode.createAvpathSyntaxError(t, columnName, -1);
  17.   }
  18.   return values;
  19. }

代码示例来源：origin: org.talend.components/processing-runtime

  1. /**
  2.  * Use an AVPath to extract data from an indexed record
  3.  * 
  4.  * @param record an indexed record
  5.  * @param avPath the path to elements to extract (can be one or multiples elements)
  6.  * @return the extracted data as a list.
  7.  */
  8. public static List<Evaluator.Ctx> getInputFields(IndexedRecord record, String avPath) {
  9.   // Adapt non-avpath syntax to avpath.
  10.   // TODO: This should probably not be automatic, use the actual syntax.
  11.   if (!avPath.startsWith("."))
  12.     avPath = "." + avPath;
  13.   Try<scala.collection.immutable.List<Evaluator.Ctx>> result =
  14.       wandou.avpath.package$.MODULE$.select(record, avPath);
  15.   List<Evaluator.Ctx> results = new ArrayList<Evaluator.Ctx>();
  16.   if (result.isSuccess()) {
  17.     for (Evaluator.Ctx ctx : JavaConversions.asJavaCollection(result.get())) {
  18.       results.add(ctx);
  19.     }
  20.   } else {
  21.     // Evaluating the expression failed, and we can handle the exception.
  22.     throw ProcessingErrorCode.createAvpathSyntaxError(result.failed().get(), avPath, -1);
  23.   }
  24.   return results;
  25. }

代码示例来源：origin: Talend/components

  1. private List<Object> getInputFields(IndexedRecord inputRecord, String columnName) {
  2.   // Adapt non-avpath syntax to avpath.
  3.   // TODO: This should probably not be automatic, use the actual syntax.
  4.   if (!columnName.startsWith("."))
  5.     columnName = "." + columnName;
  6.   Try<scala.collection.immutable.List<Evaluator.Ctx>> result = wandou.avpath.package$.MODULE$.select(inputRecord,
  7.       columnName);
  8.   List<Object> values = new ArrayList<Object>();
  9.   if (result.isSuccess()) {
  10.     for (Evaluator.Ctx ctx : JavaConversions.asJavaCollection(result.get())) {
  11.       values.add(ctx.value());
  12.     }
  13.   } else {
  14.     // Evaluating the expression failed, and we can handle the exception.
  15.     Throwable t = result.failed().get();
  16.     throw ProcessingErrorCode.createAvpathSyntaxError(t, columnName, -1);
  17.   }
  18.   return values;
  19. }

代码示例来源：origin: Talend/components

  1. /**
  2.  * Use an AVPath to extract data from an indexed record
  3.  * 
  4.  * @param record an indexed record
  5.  * @param avPath the path to elements to extract (can be one or multiples elements)
  6.  * @return the extracted data as a list.
  7.  */
  8. public static List<Evaluator.Ctx> getInputFields(IndexedRecord record, String avPath) {
  9.   // Adapt non-avpath syntax to avpath.
  10.   // TODO: This should probably not be automatic, use the actual syntax.
  11.   if (!avPath.startsWith("."))
  12.     avPath = "." + avPath;
  13.   Try<scala.collection.immutable.List<Evaluator.Ctx>> result =
  14.       wandou.avpath.package$.MODULE$.select(record, avPath);
  15.   List<Evaluator.Ctx> results = new ArrayList<Evaluator.Ctx>();
  16.   if (result.isSuccess()) {
  17.     for (Evaluator.Ctx ctx : JavaConversions.asJavaCollection(result.get())) {
  18.       results.add(ctx);
  19.     }
  20.   } else {
  21.     // Evaluating the expression failed, and we can handle the exception.
  22.     throw ProcessingErrorCode.createAvpathSyntaxError(result.failed().get(), avPath, -1);
  23.   }
  24.   return results;
  25. }

代码示例来源：origin: com.lightbend.akka/akka-stream-alpakka-file

  1. @Override
  2. public void preStart() {
  3.  chunkCallback =
  4.    createAsyncCallback(
  5.      (tryInteger) -> {
  6.       if (tryInteger.isSuccess()) {
  7.        int readBytes = tryInteger.get();
  8.        if (readBytes > 0) {
  9.         buffer.flip();
  10.         push(out, ByteString.fromByteBuffer(buffer));
  11.         position += readBytes;
  12.         buffer.clear();
  13.        } else {
  14.         // hit end, try again in a while
  15.         scheduleOnce("poll", pollingInterval);
  16.        }
  17.       } else {
  18.        failStage(tryInteger.failed().get());
  19.       }
  20.      });
  21. }

代码示例来源：origin: org.opendaylight.controller/sal-distributed-datastore

  1. final TransactionContextWrapper newTransactionContextWrapper(final TransactionProxy parent, final String shardName) {
  2.   final TransactionContextWrapper transactionContextWrapper =
  3.       new TransactionContextWrapper(parent.getIdentifier(), actorContext);
  4.   Future<PrimaryShardInfo> findPrimaryFuture = findPrimaryShard(shardName, parent.getIdentifier());
  5.   if(findPrimaryFuture.isCompleted()) {
  6.     Try<PrimaryShardInfo> maybe = findPrimaryFuture.value().get();
  7.     if(maybe.isSuccess()) {
  8.       onFindPrimaryShardSuccess(maybe.get(), parent, shardName, transactionContextWrapper);
  9.     } else {
  10.       onFindPrimaryShardFailure(maybe.failed().get(), parent, shardName, transactionContextWrapper);
  11.     }
  12.   } else {
  13.     findPrimaryFuture.onComplete(new OnComplete<PrimaryShardInfo>() {
  14.       @Override
  15.       public void onComplete(final Throwable failure, final PrimaryShardInfo primaryShardInfo) {
  16.         if (failure == null) {
  17.           onFindPrimaryShardSuccess(primaryShardInfo, parent, shardName, transactionContextWrapper);
  18.         } else {
  19.           onFindPrimaryShardFailure(failure, parent, shardName, transactionContextWrapper);
  20.         }
  21.       }
  22.     }, actorContext.getClientDispatcher());
  23.   }
  24.   return transactionContextWrapper;
  25. }

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

Try

相关文章

    查看更多

    热门标签

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

    最新文章

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