本文整理了Java中ch.lambdaj.Lambda.selectFirst()方法的一些代码示例，展示了Lambda.selectFirst()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Lambda.selectFirst()方法的具体详情如下：
包路径：ch.lambdaj.Lambda
类名称：Lambda
方法名：selectFirst
[英]Selects the first object in the given iterable that matches the given hamcrest Matcher Actually it handles also Maps, Arrays and Iterator by collecting their values. Note that this method accepts an Object in order to be used in conjunction with the Lambda#forEach(Iterable).
[中]选择给定iterable中与给定hamcrest匹配器匹配的第一个对象，该匹配器实际上还通过收集其值来处理映射、数组和迭代器。请注意，此方法接受一个对象，以便与Lambda#forEach（Iterable）一起使用。
代码示例来源：origin: mariofusco/lambdaj
/**
* Returns true if the given iterable contains at least an item that matches the given hamcrest Matcher
* Actually it handles also Maps, Arrays and Iterator by collecting their values.
* Note that this method accepts an Object in order to be used in conjunction with the {@link Lambda#forEach(Iterable)}.
* @param iterable The iterable of objects to be filtered
* @param matcher The hamcrest Matcher used to filter the given iterable
* @return True if the given iterable contains at least an item that matches the given hamcrest Matcher false otherwise
*/
public static boolean exists(Object iterable, Matcher<?> matcher) {
return selectFirst(iterable, matcher) != null;
}代码示例来源：origin: mariofusco/lambdaj
/**
* Selects the first object in this iterable that matches the given hamcrest Matcher
* @param matcher The hamcrest Matcher used to retain the given iterable
* @return The first object in the given iterable that matches the given hamcrest Matcher or null if there is no such object
*/
public T first(Matcher<?> matcher) {
return (T)Lambda.selectFirst(getInner(), matcher);
}代码示例来源：origin: net.flexmojos.oss/flexmojos-maven-plugin
protected Artifact getDependency( Matcher<? extends Artifact>... matchers )
{
return selectFirst(getDependencies(), allOf(matchers));
}代码示例来源：origin: CloudSlang/cloud-slang
private LanguageEventData selectByEventType(List<LanguageEventData> data, String eventType) {
return selectFirst(data, having(on(LanguageEventData.class).getEventType(), equalTo(eventType)));
}代码示例来源：origin: lordofthejars/nosql-unit
@Override
public boolean compare(Neo4jConnectionCallback connection, InputStream dataset) throws NoSqlAssertionError,
Throwable {
DataParser dataParser = new DataParser();
List<Object> expectedObjects = dataParser.readValues(dataset);
Multimap<Class<?>, Object> expectedGroupByClass = groupByClass(expectedObjects);
Set<Class<?>> expectedClasses = expectedGroupByClass.keySet();
for (Class<?> expectedClass : expectedClasses) {
Collection<Object> expectedObjectsByClass = expectedGroupByClass.get(expectedClass);
List<Object> insertedObjects = findAndFetchAllEntitiesByClass(neo4jTemplate(connection), expectedClass);
for (Object expectedObject : expectedObjectsByClass) {
Object selectFirst = selectFirst(insertedObjects, equalTo(expectedObject));
if(selectFirst == null) {
throw new NoSqlAssertionError(String.format("Object %s is not found in graph.", expectedObject.toString()));
}
}
}
return true;
}代码示例来源：origin: CloudSlang/cloud-slang
private long getCurrentId(Map<String, Long> stepReferences, Deque<Step> steps) {
Long currentId;
long max = Lambda.max(stepReferences);
Map.Entry maxEntry = selectFirst(stepReferences.entrySet(),
having(on(Map.Entry.class).getValue(), equalTo(max)));
String referenceKey = (String) (maxEntry).getKey();
Step step = null;
for (Step stepItem : steps) {
if (stepItem.getName().equals(referenceKey)) {
step = stepItem;
break;
}
}
if (step == null || !step.isParallelLoop()) {
// the reference is not a step or is not a parallel loop step
currentId = max + NUMBER_OF_STEP_EXECUTION_STEPS;
} else {
//async step
currentId = max + NUMBER_OF_STEP_EXECUTION_STEPS + NUMBER_OF_PARALLEL_LOOP_EXECUTION_STEPS;
}
return currentId;
}代码示例来源：origin: io.cloudslang.lang/cloudslang-compiler
private long getCurrentId(Map<String, Long> stepReferences, Deque<Step> steps) {
Long currentId;
long max = Lambda.max(stepReferences);
Map.Entry maxEntry = selectFirst(stepReferences.entrySet(),
having(on(Map.Entry.class).getValue(), equalTo(max)));
String referenceKey = (String) (maxEntry).getKey();
Step step = null;
for (Step stepItem : steps) {
if (stepItem.getName().equals(referenceKey)) {
step = stepItem;
break;
}
}
if (step == null || !step.isParallelLoop()) {
// the reference is not a step or is not a parallel loop step
currentId = max + NUMBER_OF_STEP_EXECUTION_STEPS;
} else {
//async step
currentId = max + NUMBER_OF_STEP_EXECUTION_STEPS + NUMBER_OF_PARALLEL_LOOP_EXECUTION_STEPS;
}
return currentId;
}代码示例来源：origin: com.lordofthejars/nosqlunit-neo4j
@Override
public boolean compare(Neo4jConnectionCallback connection, InputStream dataset) throws NoSqlAssertionError,
Throwable {
DataParser dataParser = new DataParser();
List<Object> expectedObjects = dataParser.readValues(dataset);
Multimap<Class<?>, Object> expectedGroupByClass = groupByClass(expectedObjects);
Set<Class<?>> expectedClasses = expectedGroupByClass.keySet();
for (Class<?> expectedClass : expectedClasses) {
Collection<Object> expectedObjectsByClass = expectedGroupByClass.get(expectedClass);
List<Object> insertedObjects = findAndFetchAllEntitiesByClass(neo4jTemplate(connection), expectedClass);
for (Object expectedObject : expectedObjectsByClass) {
Object selectFirst = selectFirst(insertedObjects, equalTo(expectedObject));
if(selectFirst == null) {
throw new NoSqlAssertionError(String.format("Object %s is not found in graph.", expectedObject.toString()));
}
}
}
return true;
}代码示例来源：origin: io.openscore.lang/score-lang-compiler
private Map<String, Executable> fetchFlowReferences(Executable executable,
Collection<Executable> availableDependencies,
Map<String, Executable> resolvedDependencies) {
for (String refId : executable.getDependencies()) {
//if it is already in the references we do nothing
if (resolvedDependencies.get(refId) == null) {
Executable matchingRef = Lambda.selectFirst(availableDependencies, having(on(Executable.class).getId(), equalTo(refId)));
if (matchingRef == null) {
throw new RuntimeException("Reference: \'" + refId + "\' in executable: \'"
+ executable.getName() + "\', wasn't found in path");
}
//first we put the reference on the map
resolvedDependencies.put(matchingRef.getId(), matchingRef);
if (matchingRef.getType().equals(SlangTextualKeys.FLOW_TYPE)) {
//if it is a flow we recursively
resolvedDependencies.putAll(fetchFlowReferences(matchingRef, availableDependencies, resolvedDependencies));
}
}
}
return resolvedDependencies;
}代码示例来源：origin: com.lordofthejars/nosqlunit-core
private SelectiveMatcher findSelectiveMatcherByConnectionIdentifier(
SelectiveMatcher[] selectiveMatchers) {
return selectFirst(
selectiveMatchers,
having(on(SelectiveMatcher.class).identifier(),
equalTo(identifier)).and(
having(on(SelectiveMatcher.class).location(),
notNullValue())));
}代码示例来源：origin: lordofthejars/nosql-unit
public ManagedMongoDbLifecycleManager getStartedServer(int port) {
return selectFirst(
this.servers,
having(on(ManagedMongoDbLifecycleManager.class).getPort(),
is(port)).and(having(on(ManagedMongoDbLifecycleManager.class).isReady(), is(true))));
}代码示例来源：origin: lordofthejars/nosql-unit
private SelectiveMatcher findSelectiveMatcherByConnectionIdentifier(
SelectiveMatcher[] selectiveMatchers) {
return selectFirst(
selectiveMatchers,
having(on(SelectiveMatcher.class).identifier(),
equalTo(identifier)).and(
having(on(SelectiveMatcher.class).location(),
notNullValue())));
}代码示例来源：origin: lordofthejars/nosql-unit
public ManagedMongoDbLifecycleManager getStoppedServer(int port) {
return selectFirst(
this.servers,
having(on(ManagedMongoDbLifecycleManager.class).getPort(),
is(port)).and(having(on(ManagedMongoDbLifecycleManager.class).isReady(), is(false))));
}代码示例来源：origin: com.lordofthejars/nosqlunit-mongodb
public ManagedMongoDbLifecycleManager getStartedServer(int port) {
return selectFirst(
this.servers,
having(on(ManagedMongoDbLifecycleManager.class).getPort(),
is(port)).and(having(on(ManagedMongoDbLifecycleManager.class).isReady(), is(true))));
}代码示例来源：origin: CloudSlang/cloud-slang
private Map<String, Executable> fetchFlowReferences(Executable executable,
Collection<Executable> availableDependencies,
Map<String, Executable> resolvedDependencies) {
for (String refId : executable.getExecutableDependencies()) {
//if it is already in the references we do nothing
if (resolvedDependencies.get(refId) == null) {
Executable matchingRef = selectFirst(availableDependencies,
having(on(Executable.class).getId(), equalTo(refId)));
if (matchingRef == null) {
throw new RuntimeException("Reference: \'" + refId + "\' in executable: \'" +
executable.getName() + "\', wasn't found in path");
}
//first we put the reference on the map
resolvedDependencies.put(matchingRef.getId(), matchingRef);
if (matchingRef.getType().equals(SlangTextualKeys.FLOW_TYPE)) {
//if it is a flow we recursively
resolvedDependencies
.putAll(fetchFlowReferences(matchingRef, availableDependencies, resolvedDependencies));
}
}
}
return resolvedDependencies;
}代码示例来源：origin: com.lordofthejars/nosqlunit-mongodb
public ManagedMongoDbLifecycleManager getStoppedServer(int port) {
return selectFirst(
this.servers,
having(on(ManagedMongoDbLifecycleManager.class).getPort(),
is(port)).and(having(on(ManagedMongoDbLifecycleManager.class).isReady(), is(false))));
}代码示例来源：origin: lordofthejars/nosql-unit
public ManagedRedisLifecycleManager getStartedServer(int port) {
if(this.master.getPort() == port && this.master.isReady()) {
return this.master;
}
return selectFirst(
this.slaveServers,
having(on(ManagedRedisLifecycleManager.class).getPort(),
is(port)).and(having(on(ManagedRedisLifecycleManager.class).isReady(), is(true))));
}代码示例来源：origin: lordofthejars/nosql-unit
public ManagedRedisLifecycleManager getStoppedServer(int port) {
if(this.master.getPort() == port && !this.master.isReady()) {
return this.master;
}
return selectFirst(
this.slaveServers,
having(on(ManagedRedisLifecycleManager.class).getPort(),
is(port)).and(having(on(ManagedRedisLifecycleManager.class).isReady(), is(false))));
}代码示例来源：origin: com.lordofthejars/nosqlunit-redis
public ManagedRedisLifecycleManager getStartedServer(int port) {
if(this.master.getPort() == port && this.master.isReady()) {
return this.master;
}
return selectFirst(
this.slaveServers,
having(on(ManagedRedisLifecycleManager.class).getPort(),
is(port)).and(having(on(ManagedRedisLifecycleManager.class).isReady(), is(true))));
}代码示例来源：origin: com.lordofthejars/nosqlunit-redis
public ManagedRedisLifecycleManager getStoppedServer(int port) {
if(this.master.getPort() == port && !this.master.isReady()) {
return this.master;
}
return selectFirst(
this.slaveServers,
having(on(ManagedRedisLifecycleManager.class).getPort(),
is(port)).and(having(on(ManagedRedisLifecycleManager.class).isReady(), is(false))));
}内容来源于网络，如有侵权，请联系作者删除！