@@ -31,7 +31,7 @@ public void testToObservableNoError() {
31
31
final TestSubscriber <Response > tester = new TestSubscriber <>();
32
32
33
33
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" ));
35
35
o1 .subscribe (tester );
36
36
tester .awaitTerminalEvent ();
37
37
tester .assertTerminalEvent ();
@@ -51,7 +51,7 @@ public void testToObservableError() {
51
51
final TestSubscriber <Response > tester = new TestSubscriber <>();
52
52
53
53
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" ));
55
55
o1 .subscribe (tester );
56
56
tester .awaitTerminalEvent ();
57
57
tester .assertTerminalEvent ();
@@ -71,7 +71,7 @@ public void testObserveNoError() {
71
71
final TestSubscriber <Response > tester = new TestSubscriber <>();
72
72
73
73
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" ));
75
75
o1 .subscribe (tester );
76
76
tester .awaitTerminalEvent ();
77
77
tester .assertTerminalEvent ();
@@ -91,7 +91,7 @@ public void testObserveError() {
91
91
final TestSubscriber <Response > tester = new TestSubscriber <>();
92
92
93
93
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" ));
95
95
o1 .subscribe (tester );
96
96
tester .awaitTerminalEvent ();
97
97
tester .assertTerminalEvent ();
@@ -111,7 +111,7 @@ public void testObserveMultiple() {
111
111
final TestSubscriber <Response > tester = new TestSubscriber <>();
112
112
113
113
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" ));
115
115
Observable <Response > o2 = AsyncHttpObservable .observe (() -> client .prepareGet ("http://www.wisc.edu" ).setFollowRedirect (true ));
116
116
Observable <Response > o3 = AsyncHttpObservable .observe (() -> client .prepareGet ("http://www.umn.edu" ).setFollowRedirect (true ));
117
117
Observable <Response > all = Observable .merge (o1 , o2 , o3 );
0 commit comments