Fixed EVERYTHING

Azure · Oct 27, 2020 · de600a5 · de600a5
1 parent 2c0aa4e
commit de600a5
Show file tree

Hide file tree

Showing 2 changed files with 248 additions and 103 deletions.
diff --git a/...st/java/com/azure/communication/administration/PhoneNumberAsyncClientIntegrationTest.java b/...st/java/com/azure/communication/administration/PhoneNumberAsyncClientIntegrationTest.java
@@ -532,11 +532,12 @@ public void beginCreateSearch(HttpClient httpClient) {
     @MethodSource("com.azure.core.test.TestBase#getHttpClients")
     public void beginPurchaseSearch(HttpClient httpClient) {
         Duration pollInterval = Duration.ofSeconds(1);
+        PhoneNumberAsyncClient client = this.getClient(httpClient);
         PollerFlux<PhoneNumberSearch, PhoneNumberSearch> poller =
-            this.getClient(httpClient).beginPurchaseSearch(SEARCH_ID, pollInterval);
+            client.beginPurchaseSearch(SEARCH_ID, pollInterval);
         AsyncPollResponse<PhoneNumberSearch, PhoneNumberSearch> asyncRes = 
-            poller.takeUntil(apr -> apr.getStatus() == LongRunningOperationStatus.SUCCESSFULLY_COMPLETED).
-            blockLast();
+            poller.takeUntil(apr -> apr.getStatus() == LongRunningOperationStatus.SUCCESSFULLY_COMPLETED)
+            .blockLast();
         PhoneNumberSearch testResult = asyncRes.getValue();
         assertEquals(SearchStatus.SUCCESS, testResult.getStatus());
     }