package edu.mit.streamjit.impl.distributed.node;

import java.io.IOException;

/**
 * StreamNode side communication interface.
 * 
 * @author Sumanan sumanan@mit.edu
 * @since May 14, 2013
 */
public interface Connection {

	public <T> T readObject() throws IOException, ClassNotFoundException;

	public boolean writeObject(Object obj) throws IOException;

	public boolean closeConnection() throws IOException;

	public boolean isStillConnected();
}

@@ -294,83 +294,404 @@
 ;%0A%0A%09
-public boolean writeObject(Object obj) throws IOException;%0A%0A%09public boolean
+/**%0A%09 * Write a object to the connection. %3C/p%3Ethrows exception if failed. So no return value needed.%0A%09 * %0A%09 * @throws IOException%0A%09 */%0A%09public void writeObject(Object obj) throws IOException;%0A%0A%09/**%0A%09 * Close the connection. This function is responsible for all kind of resource cleanup. %3C/p%3Ethrows exception if failed. So no%0A%09 * return value needed.%0A%09 * %0A%09 * @throws IOException%0A%09 */%0A%09public void
  clo

return type changed from boolean to void