pl.edu.agh.age.compute.stream.emas

Class PairPipeline

java.lang.Object

pl.edu.agh.age.compute.stream.emas.PairPipeline

public final class PairPipeline
extends java.lang.Object

Processing definition for pairs of EmasAgent.

See Also:

Pipeline

Field Summary

Fields

Modifier and Type	Field and Description
private io.vavr.collection.List<io.vavr.Tuple2<EmasAgent,EmasAgent>>	pairs

Constructor Summary

Constructors

Constructor and Description
PairPipeline(io.vavr.collection.List<io.vavr.Tuple2<EmasAgent,EmasAgent>> pairs)

Method Summary

Modifier and Type	Method and Description
io.vavr.Tuple2<Pipeline,Pipeline>	encounter(java.util.function.Predicate<EmasAgent> reproductionPredicate, java.util.function.Function<io.vavr.Tuple2<EmasAgent,EmasAgent>,io.vavr.Tuple2<io.vavr.collection.Seq<EmasAgent>,EmasAgent>> reproductionStrategy, java.util.function.Function<io.vavr.Tuple2<EmasAgent,EmasAgent>,io.vavr.collection.Seq<EmasAgent>> fightingStrategy) Performs an agent encounter.
private static io.vavr.Tuple2<io.vavr.collection.Seq<EmasAgent>,EmasAgent>	encounterPair(io.vavr.Tuple2<EmasAgent,EmasAgent> pair, java.util.function.Predicate<EmasAgent> reproductionPredicate, java.util.function.Function<io.vavr.Tuple2<EmasAgent,EmasAgent>,io.vavr.Tuple2<io.vavr.collection.Seq<EmasAgent>,EmasAgent>> reproductionStrategy, java.util.function.Function<io.vavr.Tuple2<EmasAgent,EmasAgent>,io.vavr.collection.Seq<EmasAgent>> fightingStrategy)
Pipeline	fight(java.util.function.Function<io.vavr.Tuple2<EmasAgent,EmasAgent>,io.vavr.collection.Seq<EmasAgent>> fightingStrategy) Fight in pairs.
Pipeline	fight(io.vavr.Function2<EmasAgent,EmasAgent,io.vavr.collection.Seq<EmasAgent>> fightingStrategy)
io.vavr.Tuple2<Pipeline,Pipeline>	reproduce(java.util.function.Function<io.vavr.Tuple2<EmasAgent,EmasAgent>,io.vavr.Tuple2<io.vavr.collection.Seq<EmasAgent>,EmasAgent>> reproductionStrategy) Reproduce in pairs.
io.vavr.Tuple2<Pipeline,Pipeline>	reproduce(io.vavr.Function2<EmasAgent,EmasAgent,io.vavr.Tuple2<io.vavr.collection.Seq<EmasAgent>,EmasAgent>> reproductionStrategy)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

pairs

private final io.vavr.collection.List<io.vavr.Tuple2<EmasAgent,EmasAgent>> pairs

Constructor Detail

PairPipeline

PairPipeline(io.vavr.collection.List<io.vavr.Tuple2<EmasAgent,EmasAgent>> pairs)

Method Detail

reproduce

public io.vavr.Tuple2<Pipeline,Pipeline> reproduce(java.util.function.Function<io.vavr.Tuple2<EmasAgent,EmasAgent>,io.vavr.Tuple2<io.vavr.collection.Seq<EmasAgent>,EmasAgent>> reproductionStrategy)

Reproduce in pairs.

Parameters:

reproductionStrategy - a function taking a pair of agents as an argument and returning a new set of agents that should replace this pair. Parents should also be returned in this set if they should stay in the new population.

Returns:

the tuple containing parent and child agents pipelines

reproduce

public io.vavr.Tuple2<Pipeline,Pipeline> reproduce(io.vavr.Function2<EmasAgent,EmasAgent,io.vavr.Tuple2<io.vavr.collection.Seq<EmasAgent>,EmasAgent>> reproductionStrategy)

fight

public Pipeline fight(java.util.function.Function<io.vavr.Tuple2<EmasAgent,EmasAgent>,io.vavr.collection.Seq<EmasAgent>> fightingStrategy)

Fight in pairs.

Parameters:

fightingStrategy - a function taking a pair of agents as an argument and returning a new set of agents that should replace this pair.

Returns:

a new Pipeline for new population

fight

public Pipeline fight(io.vavr.Function2<EmasAgent,EmasAgent,io.vavr.collection.Seq<EmasAgent>> fightingStrategy)

encounter

public io.vavr.Tuple2<Pipeline,Pipeline> encounter(java.util.function.Predicate<EmasAgent> reproductionPredicate,
                                                   java.util.function.Function<io.vavr.Tuple2<EmasAgent,EmasAgent>,io.vavr.Tuple2<io.vavr.collection.Seq<EmasAgent>,EmasAgent>> reproductionStrategy,
                                                   java.util.function.Function<io.vavr.Tuple2<EmasAgent,EmasAgent>,io.vavr.collection.Seq<EmasAgent>> fightingStrategy)

Performs an agent encounter. If both agents meet a given reproduction predicate - they reproduce themselves with a given reproduction strategy. Otherwise they fight with each other with a given fight strategy.

Parameters:

reproductionPredicate - the reproduction predicate

reproductionStrategy - a function taking a pair of agents as an argument and returning a new set of agents that should replace this pair. Parents should also be returned in this set if they should stay in the new population.

fightingStrategy - a function taking a pair of agents as an argument and returning a new set of agents that should replace this pair.

Returns:

a new Pipeline for new population

encounterPair

private static io.vavr.Tuple2<io.vavr.collection.Seq<EmasAgent>,EmasAgent> encounterPair(io.vavr.Tuple2<EmasAgent,EmasAgent> pair,
                                                                                         java.util.function.Predicate<EmasAgent> reproductionPredicate,
                                                                                         java.util.function.Function<io.vavr.Tuple2<EmasAgent,EmasAgent>,io.vavr.Tuple2<io.vavr.collection.Seq<EmasAgent>,EmasAgent>> reproductionStrategy,
                                                                                         java.util.function.Function<io.vavr.Tuple2<EmasAgent,EmasAgent>,io.vavr.collection.Seq<EmasAgent>> fightingStrategy)