[Assorted-commits] SF.net SVN: assorted:[1003] java-reactor/trunk/src/reactor/ReactorTest.java
Brought to you by:
yangzhang
From: <yan...@us...> - 2008-10-08 03:34:56
|
Revision: 1003 http://assorted.svn.sourceforge.net/assorted/?rev=1003&view=rev Author: yangzhang Date: 2008-10-08 03:34:52 +0000 (Wed, 08 Oct 2008) Log Message: ----------- shutdown test Modified Paths: -------------- java-reactor/trunk/src/reactor/ReactorTest.java Modified: java-reactor/trunk/src/reactor/ReactorTest.java =================================================================== --- java-reactor/trunk/src/reactor/ReactorTest.java 2008-10-07 22:35:53 UTC (rev 1002) +++ java-reactor/trunk/src/reactor/ReactorTest.java 2008-10-08 03:34:52 UTC (rev 1003) @@ -112,7 +112,7 @@ final InetSocketAddress serverSa; serverSa = new InetSocketAddress(localhost, serverPort); final Reactor r = new Reactor(); - ReactorHandler h = new AbstractHandler() { + r.register(SessionType.STREAM, null, serverSa, new AbstractHandler() { @Override public void handleAccept(Session listenerSession, @@ -137,8 +137,7 @@ } } - }; - r.register(SessionType.STREAM, null, serverSa, h); + }); r.schedule(new Runnable() { public void run() { r.register(SessionType.STREAM, serverSa, null, @@ -160,6 +159,7 @@ System.out.println("got back: '" + Charset.forName("us-ascii").decode( buf) + "'"); + r.shutdown(); } }); } This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |