package suikwasha.distributedalgorithm.util;

import suikwasha.distributedalgorithm.framework.Message;
import suikwasha.distributedalgorithm.framework.Port;
import fj.P;
import fj.P2;

public class Commons
{
	public static P2<Message,Port> RECV(Port... ports)
	{
		while(true){
			for(Port p : ports){
				Message message = p.tryReceive();
				if(message != null){
					return P.p(message,p);
				}
			}
		}
	}

}