TestAsyncComplex2.recaf

package generated;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import recaf.demo.cps.AsyncFull;
 
class MyPrinter{
	public MyPrinter(){}

	public Void print(String msg) {
		System.out.println(msg);		
		return null;
	}	
} 
 
public class TestAsyncComplex2 {

    private static recaf AsyncFull<Integer> alg = new AsyncFull<Integer>() {};

	public Void pause(Integer sleeptime) {
	    try {   
    	    new Thread().sleep(sleeptime);
    	    return null;
    	} catch (InterruptedException ex) {
    		return null;
    	}
	}
	

	recaff CompletableFuture<Integer> op() {
    	if (1 < 2) {	
    		pause(2500);
    		new MyPrinter().print("delayed op");
       		return 42; 
     	}
     	return 41;
  	}

	recaff CompletableFuture<Integer> op2() {
    	if (1 < 2) {
       		await Integer x = op();
    		await Integer y = op();
    		return x + y;
     	}
     	pause(5000);
     	return 41;
  	}
  	
  	public static void main(String[] args) throws InterruptedException, ExecutionException{
  		CompletableFuture<Integer> answer;
  				
  		answer = new TestAsyncComplex2().op2();
			
		new MyPrinter().print("main");
		
  		System.out.println(answer.get());
  	}
}