scala.util.Either.right()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(10.9k)|赞(0)|评价(0)|浏览(123)

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

Either.right介绍

暂无

代码示例

代码示例来源:origin: json-path/JsonPath

public Result runBoon() {
  String result = null;
  String error = null;
  long time;
  Iterator<Object> query = null;
  long now = System.currentTimeMillis();
  try {
    if (!optionAsValues) {
      throw new UnsupportedOperationException("Not supported!");
    }
    io.gatling.jsonpath.JsonPath jsonPath = JsonPath$.MODULE$.compile(path).right().get();
    JsonParser jsonParser = new JsonParserCharArray();
    Object jsonModel = jsonParser.parse(json);
    query = jsonPath.query(jsonModel);
  } catch (Exception e) {
    error = getError(e);
  } finally {
    time = System.currentTimeMillis() - now;
    if (query != null) {
      List<Object> res = new ArrayList<Object>();
      while (query.hasNext()) {
        res.add(query.next());
      }
      ObjectMapper mapper = new ObjectMapperImpl();
      result = mapper.toJson(res);
    }
    return new Result("boon", time, result, error);
  }
}

代码示例来源:origin: com.typesafe.play/play_2.11

static <A, B> Accumulator<ByteString, F.Either<Result, A>> delegate(play.api.mvc.BodyParser<B> delegate, Function<B, A> transform, Http.RequestHeader request) {
    Accumulator<ByteString, scala.util.Either<play.api.mvc.Result, B>> javaAccumulator = delegate.apply(request.asScala()).asJava();
      
    return javaAccumulator.map(result -> {
        if (result.isLeft()) {
          return F.Either.Left(result.left().get().asJava());
        } else {
          return F.Either.Right(transform.apply(result.right().get()));
        }
      },
      JavaParsers.trampoline());
  }
}

代码示例来源:origin: com.typesafe.play/play_2.12

static <A, B> Accumulator<ByteString, F.Either<Result, A>> delegate(play.api.mvc.BodyParser<B> delegate, Function<B, A> transform, Http.RequestHeader request) {
    Accumulator<ByteString, scala.util.Either<play.api.mvc.Result, B>> javaAccumulator = delegate.apply(request.asScala()).asJava();
      
    return javaAccumulator.map(result -> {
        if (result.isLeft()) {
          return F.Either.Left(result.left().get().asJava());
        } else {
          return F.Either.Right(transform.apply(result.right().get()));
        }
      },
      JavaParsers.trampoline());
  }
}

代码示例来源:origin: com.typesafe.play/play

static <A, B> Accumulator<ByteString, F.Either<Result, A>> delegate(play.api.mvc.BodyParser<B> delegate, Function<B, A> transform, Http.RequestHeader request) {
    Accumulator<ByteString, scala.util.Either<play.api.mvc.Result, B>> javaAccumulator = delegate.apply(request.asScala()).asJava();
      
    return javaAccumulator.map(result -> {
        if (result.isLeft()) {
          return F.Either.Left(result.left().get().asJava());
        } else {
          return F.Either.Right(transform.apply(result.right().get()));
        }
      },
      JavaParsers.trampoline());
  }
}

代码示例来源:origin: com.typesafe.play/play

/**
 * Delegates underlying functionality to another body parser and converts the
 * result to Java API.
 */
@Override
public play.libs.streams.Accumulator<ByteString, F.Either<Result, Http.MultipartFormData<A>>> apply(Http.RequestHeader request) {
  return delegate.apply(request.asScala())
      .asJava()
      .map(result -> {
            if (result.isLeft()) {
              return F.Either.Left(result.left().get().asJava());
            } else {
              final play.api.mvc.MultipartFormData<A> scalaData = result.right().get();
              return F.Either.Right(new DelegatingMultipartFormData(scalaData));
            }
          },
          JavaParsers.trampoline()
      );
}

代码示例来源:origin: com.typesafe.play/play_2.11

/**
 * Delegates underlying functionality to another body parser and converts the
 * result to Java API.
 */
@Override
public play.libs.streams.Accumulator<ByteString, F.Either<Result, Http.MultipartFormData<A>>> apply(Http.RequestHeader request) {
  return delegate.apply(request.asScala())
      .asJava()
      .map(result -> {
            if (result.isLeft()) {
              return F.Either.Left(result.left().get().asJava());
            } else {
              final play.api.mvc.MultipartFormData<A> scalaData = result.right().get();
              return F.Either.Right(new DelegatingMultipartFormData(scalaData));
            }
          },
          JavaParsers.trampoline()
      );
}

代码示例来源:origin: com.typesafe.play/play_2.12

/**
 * Delegates underlying functionality to another body parser and converts the
 * result to Java API.
 */
@Override
public play.libs.streams.Accumulator<ByteString, F.Either<Result, Http.MultipartFormData<A>>> apply(Http.RequestHeader request) {
  return delegate.apply(request.asScala())
      .asJava()
      .map(result -> {
            if (result.isLeft()) {
              return F.Either.Left(result.left().get().asJava());
            } else {
              final play.api.mvc.MultipartFormData<A> scalaData = result.right().get();
              return F.Either.Right(new DelegatingMultipartFormData(scalaData));
            }
          },
          JavaParsers.trampoline()
      );
}

代码示例来源:origin: srikalyc/Sql4D

public static void main(String[] args) {
    String q = "SELECT timestamp, LONG_SUM(count) AS edit_count, DOUBLE_SUM(added) AS chars_added FROM wikipedia WHERE interval BETWEEN 2010-01-01T00:00:00.000Z AND 2020-01-01T00:00:00.000Z BREAK BY 'minute' HINT('timeseries');";
    String q1 = "SELECT timestamp, page, LONG_SUM(count) AS edit_count FROM wikipedia WHERE interval BETWEEN 2010-01-01 AND 2020-01-01 AND country='United States' BREAK BY 'all' GROUP BY page  ORDER BY edit_count DESC LIMIT 10;";
    String q2 = "SELECT page, LONG_SUM(count) AS edit_count FROM wikipedia WHERE interval BETWEEN 2010-01-01T00:00:00.000Z AND 2020-01-01T00:00:00.000Z AND country='United States' BREAK BY 'minute' GROUP BY page  LIMIT 10;";
    DDataSource driver = new DDataSource("localhost", 4080, "localhost", 8082, null, 3128);
    Either<String, Either<Joiner4All, Mapper4All>> result = driver.query(q, null, null, true, "sql");
    System.out.println(result.right().get().right().get());
  }
}

代码示例来源:origin: com.yahoo.sql4d/Sql4Ddriver

public static void main(String[] args) {
    String q = "SELECT timestamp, LONG_SUM(count) AS edit_count, DOUBLE_SUM(added) AS chars_added FROM wikipedia WHERE interval BETWEEN 2010-01-01T00:00:00.000Z AND 2020-01-01T00:00:00.000Z BREAK BY 'minute' HINT('timeseries');";
    String q1 = "SELECT timestamp, page, LONG_SUM(count) AS edit_count FROM wikipedia WHERE interval BETWEEN 2010-01-01 AND 2020-01-01 AND country='United States' BREAK BY 'all' GROUP BY page  ORDER BY edit_count DESC LIMIT 10;";
    String q2 = "SELECT page, LONG_SUM(count) AS edit_count FROM wikipedia WHERE interval BETWEEN 2010-01-01T00:00:00.000Z AND 2020-01-01T00:00:00.000Z AND country='United States' BREAK BY 'minute' GROUP BY page  LIMIT 10;";
    DDataSource driver = new DDataSource("localhost", 4080, "localhost", 8082, null, 3128);
    Either<String, Either<Joiner4All, Mapper4All>> result = driver.query(q, null, null, true, "sql");
    System.out.println(result.right().get().right().get());
  }
}

代码示例来源:origin: com.yahoo.maha/maha-par-request-2

/**
 * Maps either by applying function doWithRight if the Either isRight(), otherwise, it passes the Either through
 * with cast to <E,U>
 */
public static <U, E, A> Either<E, U> map(Function<A, U> doWithRight, Either<E,A> either) {
  if (either.isRight()) {
    return new Right<>(doWithRight.apply(either.right().get()));
  } else {
    return ((Either<E, U>) either);
  }
}

代码示例来源:origin: com.yahoo.maha/maha-par-request-2

/**
 * Converts Either<E,A> to T by applying the right function or left function depending on if it isRight or isLeft
 */
public static <T, E, A> T fold(Function<E, T> doWithLeft, Function<A, T> doWithRight, Either<E,A> either) {
  if (either.isLeft()) {
    return doWithLeft.apply(either.left().get());
  } else {
    return doWithRight.apply(either.right().get());
  }
}

代码示例来源:origin: com.yahoo.sql4d/Sql4Ddriver

public List<String> getMetrics(String name, Map<String, String> reqHeaders) {
  Either<String,Tuple2<List<String>,List<String>>> aboutDataSource = aboutDataSource(name, reqHeaders);
  if (aboutDataSource.isLeft()) {
    return Lists.newArrayList();
  } 
  return aboutDataSource.right().get()._2();
}
/**

代码示例来源:origin: srikalyc/Sql4D

public List<String> getMetrics(String name, Map<String, String> reqHeaders) {
  Either<String,Tuple2<List<String>,List<String>>> aboutDataSource = aboutDataSource(name, reqHeaders);
  if (aboutDataSource.isLeft()) {
    return Lists.newArrayList();
  } 
  return aboutDataSource.right().get()._2();
}
/**

代码示例来源:origin: kframework/k

public static K parseWithModule(String theTextToParse,
                Sort startSymbol,
                Source source,
                ParseInModule kastModule) {
  return kastModule.parseString(theTextToParse, startSymbol, source)._1().right().get();
}

代码示例来源:origin: kframework/k

public void assertCleanup(Term input, Term expected) {
  Term actual = treeCleanerVisitor.apply(input).right().get();
  if (!actual.equals(expected)) {
    assertEquals(expected.toString(), actual.toString());
  }
}

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

@Override
public SSLContext clientCertificate(final ClientCertificateCredentials credentials) {
  final String clientKeyPem = credentials.getClientKey().orElse(null);
  final String clientCertificatePem = credentials.getClientCertificate().orElse(null);
  final Supplier<KeyManager[]> keyManagerSupplier = newKeyManagerFactory(clientKeyPem, clientCertificatePem);
  final Supplier<TrustManager[]> trustManagerFactory = trust.isRight()
      ? newTrustManagerFactory(trust.right().get())
      : () -> new TrustManager[]{trust.left().get()};
  return newTLSContext(keyManagerSupplier, trustManagerFactory);
}

代码示例来源:origin: kframework/k

public void throwFirstLeftException(Term input) {
    Either<Set<ParseFailedException>, Term> result = treeCleanerVisitor.apply(input);
    if (result.isRight()) {
      fail("Expected an exception but got:" + result.right().get());
    } else {
      throw result.left().get().iterator().next();
    }
  }
}

代码示例来源:origin: kframework/k

public Tuple2<Either<Set<ParseFailedException>, K>, Set<ParseFailedException>>
  parseString(String input, Sort startSymbol, Scanner scanner, Source source, int startLine, int startColumn, boolean inferSortChecks) {
  final Tuple2<Either<Set<ParseFailedException>, Term>, Set<ParseFailedException>> result
      = parseStringTerm(input, startSymbol, scanner, source, startLine, startColumn, inferSortChecks);
  Either<Set<ParseFailedException>, K> parseInfo;
  if (result._1().isLeft()) {
    parseInfo = Left.apply(result._1().left().get());
  } else {
    parseInfo = Right.apply(new TreeNodesToKORE(Outer::parseSort, inferSortChecks && strict).apply(result._1().right().get()));
  }
  return new Tuple2<>(parseInfo, result._2());
}

代码示例来源:origin: kframework/k

private K parseTerm(String pgm, ParseInModule parser) {
  Tuple2<Either<Set<ParseFailedException>, K>, Set<ParseFailedException>> result = parser.parseString(pgm, Sorts.K(), Source.apply("generated by AddBracketsTest"));
  assertEquals(0, result._2().size());
  return new TreeNodesToKORE(Outer::parseSort, false).down(result._1().right().get());
}

代码示例来源:origin: kframework/k

private void parseProgram(String input, String def, String startSymbol, int warnings, K expectedResult) {
  Module test = ParserUtils.parseMainModuleOuterSyntax(def, Source.apply("generated by RuleGrammarTest"), "TEST");
  ParseInModule parser = RuleGrammarGenerator.getCombinedGrammar(gen.getProgramsGrammar(test), true);
  Tuple2<Either<Set<ParseFailedException>, K>, Set<ParseFailedException>> rule = parser.parseString(input, Sort(startSymbol), Source.apply("generated by RuleGrammarTest"));
  printout(rule, warnings, false);
  Assert.assertEquals(expectedResult, rule._1().right().get());
}

相关文章

微信公众号

最新文章

更多