From 8169bfc820d25e8644750c7f7857f97f2e664db5 Mon Sep 17 00:00:00 2001 From: Eike Stepper Date: Mon, 13 Aug 2007 06:08:26 +0000 Subject: *** empty log message *** --- .../org/eclipse/net4j/tests/TCPTransportTest.java | 52 +++++++++++----------- 1 file changed, 26 insertions(+), 26 deletions(-) (limited to 'plugins/org.eclipse.net4j.tests') 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 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 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 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 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 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 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 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 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(); } } -- cgit v1.2.3