Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorEike Stepper2007-08-13 06:08:26 +0000
committerEike Stepper2007-08-13 06:08:26 +0000
commit8169bfc820d25e8644750c7f7857f97f2e664db5 (patch)
tree097ec1e2935bc5d97526c7056796470b546838dd /plugins/org.eclipse.net4j.tests
parentd431996e86d5230bff9aeabd84e088a6c6b3469c (diff)
downloadcdo-8169bfc820d25e8644750c7f7857f97f2e664db5.tar.gz
cdo-8169bfc820d25e8644750c7f7857f97f2e664db5.tar.xz
cdo-8169bfc820d25e8644750c7f7857f97f2e664db5.zip
*** empty log message ***
Diffstat (limited to 'plugins/org.eclipse.net4j.tests')
-rw-r--r--plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/TCPTransportTest.java52
1 files changed, 26 insertions, 26 deletions
diff --git a/plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/TCPTransportTest.java b/plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/TCPTransportTest.java
index 2ee0eb5c4c..f633ecc1d7 100644
--- a/plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/TCPTransportTest.java
+++ b/plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/TCPTransportTest.java
@@ -10,16 +10,16 @@
**************************************************************************/
package org.eclipse.net4j.tests;
-import org.eclipse.net4j.IAcceptorEvent;
import org.eclipse.net4j.IBuffer;
import org.eclipse.net4j.IBufferProvider;
import org.eclipse.net4j.IChannel;
-import org.eclipse.net4j.IConnectorChannelsEvent;
+import org.eclipse.net4j.IConnector;
import org.eclipse.net4j.Net4jUtil;
import org.eclipse.net4j.stream.ChannelInputStream;
import org.eclipse.net4j.stream.ChannelOutputStream;
import org.eclipse.net4j.tests.signal.TestSignalServerProtocolFactory;
import org.eclipse.net4j.util.container.IContainerDelta;
+import org.eclipse.net4j.util.container.IContainerEvent;
import org.eclipse.net4j.util.container.IManagedContainer;
import org.eclipse.net4j.util.event.IEvent;
import org.eclipse.net4j.util.event.IListener;
@@ -159,19 +159,19 @@ public class TCPTransportTest extends AbstractTransportTest
{
public void notifyEvent(IEvent event)
{
- if (event instanceof IAcceptorEvent)
+ if (event instanceof IContainerEvent)
{
- IAcceptorEvent e = (IAcceptorEvent)event;
- e.getConnector().addListener(new IListener()
+ IContainerEvent<IConnector> e = (IContainerEvent)event;
+ e.getDeltaElement().addListener(new IListener()
{
public void notifyEvent(IEvent event)
{
- if (event instanceof IConnectorChannelsEvent)
+ if (event instanceof IContainerEvent)
{
- IConnectorChannelsEvent e = (IConnectorChannelsEvent)event;
+ IContainerEvent<IChannel> e = (IContainerEvent)event;
if (e.getDeltaKind() == IContainerDelta.Kind.ADDED)
{
- inputStream[0] = new ChannelInputStream(e.getChannel(), 2000);
+ inputStream[0] = new ChannelInputStream(e.getDeltaElement(), 2000);
counter.countDown();
}
}
@@ -222,19 +222,19 @@ public class TCPTransportTest extends AbstractTransportTest
{
public void notifyEvent(IEvent event)
{
- if (event instanceof IAcceptorEvent)
+ if (event instanceof IContainerEvent)
{
- IAcceptorEvent e = (IAcceptorEvent)event;
- e.getConnector().addListener(new IListener()
+ IContainerEvent<IConnector> e = (IContainerEvent)event;
+ e.getDeltaElement().addListener(new IListener()
{
public void notifyEvent(IEvent event)
{
- if (event instanceof IConnectorChannelsEvent)
+ if (event instanceof IContainerEvent)
{
- IConnectorChannelsEvent e = (IConnectorChannelsEvent)event;
+ IContainerEvent<IChannel> e = (IContainerEvent)event;
if (e.getDeltaKind() == IContainerDelta.Kind.ADDED)
{
- inputStream[0] = new ChannelInputStream(e.getChannel(), 2000);
+ inputStream[0] = new ChannelInputStream(e.getDeltaElement(), 2000);
counter.countDown();
}
}
@@ -288,19 +288,19 @@ public class TCPTransportTest extends AbstractTransportTest
{
public void notifyEvent(IEvent event)
{
- if (event instanceof IAcceptorEvent)
+ if (event instanceof IContainerEvent)
{
- IAcceptorEvent e = (IAcceptorEvent)event;
- e.getConnector().addListener(new IListener()
+ IContainerEvent<IConnector> e = (IContainerEvent)event;
+ e.getDeltaElement().addListener(new IListener()
{
public void notifyEvent(IEvent event)
{
- if (event instanceof IConnectorChannelsEvent)
+ if (event instanceof IContainerEvent)
{
- IConnectorChannelsEvent e = (IConnectorChannelsEvent)event;
+ IContainerEvent<IChannel> e = (IContainerEvent)event;
if (e.getDeltaKind() == IContainerDelta.Kind.ADDED)
{
- inputStream[0] = new ChannelInputStream(e.getChannel(), 2000);
+ inputStream[0] = new ChannelInputStream(e.getDeltaElement(), 2000);
counter.countDown();
}
}
@@ -370,19 +370,19 @@ public class TCPTransportTest extends AbstractTransportTest
{
public void notifyEvent(IEvent event)
{
- if (event instanceof IAcceptorEvent)
+ if (event instanceof IContainerEvent)
{
- IAcceptorEvent e = (IAcceptorEvent)event;
- e.getConnector().addListener(new IListener()
+ IContainerEvent<IConnector> e = (IContainerEvent)event;
+ e.getDeltaElement().addListener(new IListener()
{
public void notifyEvent(IEvent event)
{
- if (event instanceof IConnectorChannelsEvent)
+ if (event instanceof IContainerEvent)
{
- IConnectorChannelsEvent e = (IConnectorChannelsEvent)event;
+ IContainerEvent<IChannel> e = (IContainerEvent)event;
if (e.getDeltaKind() == IContainerDelta.Kind.ADDED)
{
- inputStream[0] = new ChannelInputStream(e.getChannel(), 2000);
+ inputStream[0] = new ChannelInputStream(e.getDeltaElement(), 2000);
counter.countDown();
}
}

Back to the top