extracted connection future for reusing it for UDP client
Project: http://git-wip-us.apache.org/repos/asf/mina/repo Commit: http://git-wip-us.apache.org/repos/asf/mina/commit/282dc8f0 Tree: http://git-wip-us.apache.org/repos/asf/mina/tree/282dc8f0 Diff: http://git-wip-us.apache.org/repos/asf/mina/diff/282dc8f0 Branch: refs/heads/trunk Commit: 282dc8f057b91d0844ec20c5d0afca62fb1103b6 Parents: 833d6e1 Author: jvermillard <[email protected]> Authored: Sun May 12 14:24:57 2013 +0200 Committer: jvermillard <[email protected]> Committed: Sun May 12 14:24:57 2013 +0200 ---------------------------------------------------------------------- .../apache/mina/transport/nio/ConnectFuture.java | 26 +++++++++++++++ 1 files changed, 26 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mina/blob/282dc8f0/core/src/main/java/org/apache/mina/transport/nio/ConnectFuture.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/mina/transport/nio/ConnectFuture.java b/core/src/main/java/org/apache/mina/transport/nio/ConnectFuture.java new file mode 100644 index 0000000..8c33702 --- /dev/null +++ b/core/src/main/java/org/apache/mina/transport/nio/ConnectFuture.java @@ -0,0 +1,26 @@ +package org.apache.mina.transport.nio; + +import org.apache.mina.api.IoSession; +import org.apache.mina.util.AbstractIoFuture; + +public class ConnectFuture extends AbstractIoFuture<IoSession> { + + @Override + protected boolean cancelOwner(boolean mayInterruptIfRunning) { + return false; + } + + /** + * session connected + */ + public void complete(IoSession session) { + setResult(session); + } + + /** + * connection error + */ + public void error(Exception e) { + setException(e); + } +} \ No newline at end of file
