本文整理了Java中scala.util.Either.right()
方法的一些代码示例,展示了Either.right()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Either.right()
方法的具体详情如下:
包路径:scala.util.Either
类名称: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());
}
内容来源于网络,如有侵权,请联系作者删除!