org.jooby.funzy.Try.onFailure()方法的使用及代码示例

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

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

Try.onFailure介绍

[英]Run the given action if and only if this is a failure.
[中]当且仅当此操作失败时运行给定操作。

代码示例

代码示例来源:origin: jooby-project/jooby

  1. @Override
  2. public void writeSuccess() {
  3. Try.run(success::invoke)
  4. .onFailure(cause -> log.error("Error while invoking success callback", cause));
  5. }

代码示例来源:origin: jooby-project/jooby

  1. @Override
  2. public void run() {
  3. if (watcher != null) {
  4. log.debug("stopping: watcher");
  5. Try.run(watcher::stop).onFailure(ex -> log.debug("Stop of watcher resulted in error", ex));
  6. }
  7. commands.forEach(cmd -> {
  8. log.debug("stopping: " + cmd);
  9. Try.run(cmd::stop).onFailure(ex -> log.error("Stop of " + cmd + " resulted in error", ex));
  10. });
  11. }
  12. }

代码示例来源:origin: jooby-project/jooby

  1. protected void fireCloseEvent() {
  2. Throwing.Runnable task = onclose.getAndSet(null);
  3. if (task != null) {
  4. Try.run(task).onFailure(ex -> log.error("close callback resulted in error", ex));
  5. }
  6. }

代码示例来源:origin: jooby-project/jooby

  1. public void close() throws Exception {
  2. reporters.forEach(r -> Try.run(r::close)
  3. .onFailure(cause -> log.error("close of {} resulted in error", r, cause)));
  4. }

代码示例来源:origin: jooby-project/jooby

  1. private static void fireStop(final Jooby app, final Logger log,
  2. final List<Throwing.Consumer<Registry>> onStop) {
  3. // stop services
  4. onStop.forEach(c -> Try.run(() -> c.accept(app))
  5. .onFailure(x -> log.error("shutdown of {} resulted in error", c, x)));
  6. }

代码示例来源:origin: jooby-project/jooby

  1. public static void forceConverter(final AsyncRepository repo, final JacksonMapper converter) {
  2. Try.run(() -> FIELD.apply(repo.getClass()).set(repo, converter))
  3. .onFailure(x -> log.warn("Set converter resulted in error", x));
  4. }
  5. }

代码示例来源:origin: jooby-project/jooby

  1. @Override
  2. public void writeFailed(final Throwable cause) {
  3. Try.run(() -> err.onError(cause))
  4. .onFailure(ex -> log.error("Error while invoking err callback", ex));
  5. }
  6. };

代码示例来源:origin: jooby-project/jooby

  1. public void done(final Optional<Throwable> cause) {
  2. if (complete.size() > 0) {
  3. for (Route.Complete h : complete) {
  4. Try.run(() -> h.handle(req, this, cause))
  5. .onFailure(x -> LoggerFactory.getLogger(Response.class)
  6. .error("complete listener resulted in error", x));
  7. }
  8. complete.clear();
  9. }
  10. end();
  11. }

代码示例来源:origin: jooby-project/jooby

  1. @Override
  2. protected void closeInternal() {
  3. Try.run(() -> rsp.closeOutput())
  4. .onFailure(cause -> log.debug("error while closing connection", cause));
  5. }

代码示例来源:origin: jooby-project/jooby

  1. static Handler tryPage(final Handler handler, final Logger log) {
  2. return (req, rsp, ex) -> Try.run(() -> handler.handle(req, rsp, ex)).onFailure(cause -> log.debug("execution of pretty err page resulted in exception", cause));
  3. }

代码示例来源:origin: jooby-project/jooby

  1. @SuppressWarnings({"rawtypes", "unchecked"})
  2. private <T> T configure(final T source, final Config config) {
  3. List<Method> methods = Lists.newArrayList(source.getClass().getMethods());
  4. config.entrySet().forEach(o -> {
  5. String key = o.getKey();
  6. String setter = "set" + CaseFormat.LOWER_CAMEL.to(CaseFormat.UPPER_CAMEL, key);
  7. Object raw = o.getValue().unwrapped();
  8. Optional<Method> result = methods.stream()
  9. .filter(m -> m.getName().equals(setter))
  10. .findFirst();
  11. if (result.isPresent()) {
  12. Method method = result.get();
  13. Class type = method.getParameterTypes()[0];
  14. Object value = cast(type, raw);
  15. Try.run(() -> method.invoke(source, value)).onFailure(ex -> {
  16. throw new IllegalArgumentException("Bad option: <" + raw + "> for: " + method, ex);
  17. });
  18. } else {
  19. log.error("Unknown option camel.{} = {}", key, raw);
  20. }
  21. });
  22. return source;
  23. }

代码示例来源:origin: jooby-project/jooby

  1. .onFailure(x -> log.error("can't copy {}", it, x));

代码示例来源:origin: jooby-project/jooby

  1. aggregators.accept(a);
  2. a.fileset().forEach(f -> values.add(spath(f)));
  3. })).onFailure(x -> values.add(it)));
  4. raw.put(key.get(0), values);
  5. graph.put(key.get(0), key);

代码示例来源:origin: jooby-project/jooby

  1. services.forEach(exec -> Try.run(() -> exec.getValue().shutdown()).onFailure(cause -> log.error("shutdown of {} resulted in error", exec.getKey(), cause)));
  2. services.clear();
  3. });

代码示例来源:origin: jooby-project/jooby

  1. public void end() {
  2. try {
  3. if (rollbackOnly) {
  4. rollback();
  5. } else {
  6. commit();
  7. }
  8. } finally {
  9. if (readOnly) {
  10. setConnectionReadOnly(false);
  11. }
  12. String sessionId = oid(session);
  13. log.debug("closing session: {}", sessionId);
  14. Try.run(session::close)
  15. .onFailure(x -> log.error("session.close() resulted in exception: {}", sessionId, x))
  16. .onSuccess(() -> log.debug("session closed: {}", sessionId));
  17. unbind(session.getSessionFactory());
  18. }
  19. }

代码示例来源:origin: jooby-project/jooby

  1. .onFailure(x -> {
  2. log.debug("png-fallback resulted in exception", x);
  3. callback.call(null, toV8Array(v8, Arrays.asList(x.getMessage())));

代码示例来源:origin: jooby-project/jooby

  1. .orElse(false));
  2. Try.run(cluster::disconnect)
  3. .onFailure(x -> log.debug("disconnect operation resulted in exception", x));
  4. .onFailure(x -> log.debug("environment shutdown resulted in exception", x));
  5. });

代码示例来源:origin: jooby-project/jooby

  1. .onFailure(this::handleErr));
  2. new MutantImpl(injector.getInstance(ParserExecutor.class), consumes,
  3. new StrParamReferenceImpl("body", "message", ImmutableList.of(message))))))
  4. .onFailure(this::handleErr));
  5. })).onFailure(this::handleErr);
  6. });

代码示例来源:origin: jooby-project/jooby

  1. @Override
  2. default void handle(final Request req, final Response rsp, final Chain chain) throws Throwable {
  3. Sse sse = req.require(Sse.class);
  4. String path = req.path();
  5. rsp.send(new Deferred(deferred -> {
  6. try {
  7. sse.handshake(req, () -> {
  8. Try.run(() -> handle(req, sse))
  9. .onSuccess(() -> deferred.resolve(null))
  10. .onFailure(ex -> {
  11. deferred.reject(ex);
  12. Logger log = LoggerFactory.getLogger(Sse.class);
  13. log.error("execution of {} resulted in error", path, ex);
  14. });
  15. });
  16. } catch (Exception ex) {
  17. deferred.reject(ex);
  18. }
  19. }));
  20. }

代码示例来源:origin: jooby-project/jooby

  1. log.debug("Stopping {}", cstr);
  2. Try.run(session::close)
  3. .onFailure(x -> log.error("session.close() resulted in exception", x));

相关文章