Skip to content

Commit

Permalink
updates
Browse files Browse the repository at this point in the history
  • Loading branch information
douglascraigschmidt committed Feb 16, 2021
1 parent da41655 commit 953899a
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 8 deletions.
Expand Up @@ -23,7 +23,7 @@
/**
*
*/
public class COOPTests {
public class COOPClient {
/**
* This test invokes microservices to synchronously determine the
* best price for a {@code trip} using the given {@code
Expand Down Expand Up @@ -61,7 +61,7 @@ public static void runSyncTests(TripRequest trip,
private static void findFlightsSync(int iteration,
TripRequest tripRequest,
CurrencyConversion currencyConversion) {
List<TripResponse> trips = COOPTests
List<TripResponse> trips = COOPClient
.makeAllPrices()
.compute(tripRequest,
currencyConversion);
Expand Down Expand Up @@ -90,7 +90,7 @@ private static void findBestPriceSync(int iteration,
TripRequest tripRequest,
CurrencyConversion currencyConversion) {

TripResponse tripResponse = COOPTests
TripResponse tripResponse = COOPClient
.makeBestPrice()
.compute(tripRequest,
currencyConversion);
Expand Down
Expand Up @@ -20,7 +20,7 @@
* that determine the best price for flights in an airline reservation
* system.
*/
public class ReactorTests {
public class ReactorClient {
/**
* A proxy that's used to communicate with the FlightPrice
* microservice.
Expand Down
Expand Up @@ -20,7 +20,7 @@
* determine the best price for flights in an airline reservation
* system.
*/
public class RxJavaTests {
public class RxJavaClient {
/**
* A proxy that's used to communicate with the FlightPrice
* microservice.
Expand Down Expand Up @@ -136,7 +136,7 @@ private static Single<TripResponse> combineAndConvertResults(Single<TripResponse
// Call the this::convert method reference to convert the
// price using the given exchange rate when both previous
// Monos complete their processing.
.zip(tripS, rateS, RxJavaTests::convert)
.zip(tripS, rateS, RxJavaClient::convert)

// If the total processing takes more than maxTime a
// TimeoutException will be thrown.
Expand Down
4 changes: 2 additions & 2 deletions Reactor/ex5/src/main/java/ex5.java
Expand Up @@ -2,7 +2,7 @@
import datamodels.CurrencyConversion;
import datamodels.TripRequest;
import microservices.AirportList.AirportListProxySync;
import clients.ReactorTests;
import clients.ReactorClient;
import utils.Options;
import utils.RunTimer;

Expand Down Expand Up @@ -67,7 +67,7 @@ private void run() {
// This test uses Project Reactor to invoke microservices
// that asynchronously determine the best price for a
// flight from London to New York city in British pounds.
.timeRun(() -> ReactorTests.runAsyncTests(mTrip,
.timeRun(() -> ReactorClient.runAsyncTests(mTrip,
mCurrencyConversion),
"runReactorAsyncTests");

Expand Down

0 comments on commit 953899a

Please sign in to comment.