public class AndJoin extends JoinActivity {
public Continuation continuationWith(Continuation continuation) {
AndJoinContinuation k = continuation.makeAndJoinContinuation(this);
k.setNumberOfInputs(numberOfBranches);
k.resetState();
return k;
}
public void computeStateFor(Continuation k) {
((AndJoinContinuation)k).setBody(body.continuationWith(k.getNextContinuation()));