diff options
Diffstat (limited to 'plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/TCPTransportTest.java')
-rw-r--r-- | plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/TCPTransportTest.java | 15 |
1 files changed, 9 insertions, 6 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 9ddc0524ac..2ee0eb5c4c 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 @@ -12,17 +12,18 @@ 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.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.IManagedContainer; import org.eclipse.net4j.util.event.IEvent; import org.eclipse.net4j.util.event.IListener; -import org.eclipse.internal.net4j.TransportContainer; - import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; @@ -40,16 +41,17 @@ import java.util.concurrent.TimeUnit; public class TCPTransportTest extends AbstractTransportTest { @Override - protected TransportContainer createContainer() + protected IManagedContainer createContainer() { - TransportContainer container = super.createContainer(); + IManagedContainer container = super.createContainer(); container.registerFactory(new TestSignalServerProtocolFactory()); return container; } protected IBuffer provideBuffer() { - return container.getBufferProvider().provideBuffer(); + IBufferProvider bufferProvider = Net4jUtil.getBufferProvider(container); + return bufferProvider.provideBuffer(); } public void testConnect() throws Exception @@ -319,7 +321,8 @@ public class TCPTransportTest extends AbstractTransportTest { try { - ChannelOutputStream outputStream = new ChannelOutputStream(channel, container.getBufferProvider()); + IBufferProvider bufferProvider = Net4jUtil.getBufferProvider(container); + ChannelOutputStream outputStream = new ChannelOutputStream(channel, bufferProvider); PrintStream printer = new PrintStream(outputStream); StringTokenizer tokenizer = HugeData.getTokenizer(); while (tokenizer.hasMoreTokens()) |