Skip to content

Commit cbba52f

Browse files
committed
Fix tests as gatling.io has switched to https
1 parent a2c5769 commit cbba52f

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

extras/rxjava/src/test/java/org/asynchttpclient/extras/rxjava/AsyncHttpObservableTest.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ public void testToObservableNoError() {
3131
final TestSubscriber<Response> tester = new TestSubscriber<>();
3232

3333
try (AsyncHttpClient client = asyncHttpClient()) {
34-
Observable<Response> o1 = AsyncHttpObservable.toObservable(() -> client.prepareGet("http://gatling.io"));
34+
Observable<Response> o1 = AsyncHttpObservable.toObservable(() -> client.prepareGet("https://gatling.io"));
3535
o1.subscribe(tester);
3636
tester.awaitTerminalEvent();
3737
tester.assertTerminalEvent();
@@ -51,7 +51,7 @@ public void testToObservableError() {
5151
final TestSubscriber<Response> tester = new TestSubscriber<>();
5252

5353
try (AsyncHttpClient client = asyncHttpClient()) {
54-
Observable<Response> o1 = AsyncHttpObservable.toObservable(() -> client.prepareGet("http://gatling.io/ttfn"));
54+
Observable<Response> o1 = AsyncHttpObservable.toObservable(() -> client.prepareGet("https://gatling.io/ttfn"));
5555
o1.subscribe(tester);
5656
tester.awaitTerminalEvent();
5757
tester.assertTerminalEvent();
@@ -71,7 +71,7 @@ public void testObserveNoError() {
7171
final TestSubscriber<Response> tester = new TestSubscriber<>();
7272

7373
try (AsyncHttpClient client = asyncHttpClient()) {
74-
Observable<Response> o1 = AsyncHttpObservable.observe(() -> client.prepareGet("http://gatling.io"));
74+
Observable<Response> o1 = AsyncHttpObservable.observe(() -> client.prepareGet("https://gatling.io"));
7575
o1.subscribe(tester);
7676
tester.awaitTerminalEvent();
7777
tester.assertTerminalEvent();
@@ -91,7 +91,7 @@ public void testObserveError() {
9191
final TestSubscriber<Response> tester = new TestSubscriber<>();
9292

9393
try (AsyncHttpClient client = asyncHttpClient()) {
94-
Observable<Response> o1 = AsyncHttpObservable.observe(() -> client.prepareGet("http://gatling.io/ttfn"));
94+
Observable<Response> o1 = AsyncHttpObservable.observe(() -> client.prepareGet("https://gatling.io/ttfn"));
9595
o1.subscribe(tester);
9696
tester.awaitTerminalEvent();
9797
tester.assertTerminalEvent();
@@ -111,7 +111,7 @@ public void testObserveMultiple() {
111111
final TestSubscriber<Response> tester = new TestSubscriber<>();
112112

113113
try (AsyncHttpClient client = asyncHttpClient()) {
114-
Observable<Response> o1 = AsyncHttpObservable.observe(() -> client.prepareGet("http://gatling.io"));
114+
Observable<Response> o1 = AsyncHttpObservable.observe(() -> client.prepareGet("https://gatling.io"));
115115
Observable<Response> o2 = AsyncHttpObservable.observe(() -> client.prepareGet("http://www.wisc.edu").setFollowRedirect(true));
116116
Observable<Response> o3 = AsyncHttpObservable.observe(() -> client.prepareGet("http://www.umn.edu").setFollowRedirect(true));
117117
Observable<Response> all = Observable.merge(o1, o2, o3);

0 commit comments

Comments
 (0)