Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixed #2585 

Signed-off-by: Greg Wilkins <gregw@webtide.com>
This commit is contained in:
Greg Wilkins 2018-05-29 14:58:05 +02:00
parent d3b81e5372
commit 4f20447a5a
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tests/test-http-client-transport/src/test/java/org/eclipse/jetty/http/client/HttpClientStreamTest.java
View File

@ -43,7 +43,6 @@ import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.atomic.AtomicReference;
import javax.servlet.AsyncContext; import javax.servlet.AsyncContext;
import javax.servlet.DispatcherType;
import javax.servlet.ServletException; import javax.servlet.ServletException;
import javax.servlet.ServletOutputStream; import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
@ -60,7 +59,6 @@ import org.eclipse.jetty.client.util.InputStreamResponseListener;
import org.eclipse.jetty.client.util.OutputStreamContentProvider; import org.eclipse.jetty.client.util.OutputStreamContentProvider;
import org.eclipse.jetty.http.HttpStatus; import org.eclipse.jetty.http.HttpStatus;
import org.eclipse.jetty.server.Request; import org.eclipse.jetty.server.Request;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.server.ServerConnector; import org.eclipse.jetty.server.ServerConnector;
import org.eclipse.jetty.server.handler.AbstractHandler; import org.eclipse.jetty.server.handler.AbstractHandler;
import org.eclipse.jetty.toolchain.test.MavenTestingUtils; import org.eclipse.jetty.toolchain.test.MavenTestingUtils;
@ -459,13 +457,12 @@ public class HttpClientStreamTest extends AbstractTest
public void testInputStreamResponseListenerFailedBeforeResponse() throws Exception public void testInputStreamResponseListenerFailedBeforeResponse() throws Exception
{ {
start(new EmptyServerHandler()); start(new EmptyServerHandler());
//int port = connector.getLocalPort(); int port = connector instanceof ServerConnector?ServerConnector.class.cast( connector ).getLocalPort():1;
server.stop(); server.stop();
InputStreamResponseListener listener = new InputStreamResponseListener(); InputStreamResponseListener listener = new InputStreamResponseListener();
// Connect to the wrong port // Connect to the wrong port
client.newRequest("localhost", client.newRequest("localhost",port)
(connector instanceof ServerConnector?ServerConnector.class.cast( connector ).getLocalPort():1))
.scheme(getScheme()) .scheme(getScheme())
.send(listener); .send(listener);
Result result = listener.await(5, TimeUnit.SECONDS); Result result = listener.await(5, TimeUnit.SECONDS);