Addressed Ankit's comments

Azure · Oct 7, 2020 · 396c715 · 396c715
1 parent f18bf71
commit 396c715
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 7 deletions.
diff --git a/...stration/src/main/java/com/azure/communication/administration/PhoneNumberAsyncClient.java b/...stration/src/main/java/com/azure/communication/administration/PhoneNumberAsyncClient.java
@@ -775,6 +775,7 @@ Mono<Response<Void>> purchaseSearchWithResponse(String searchId, Context context
      * until it gets a result from the server
      * @return A {@link PollerFlux} object with the search result
      */
+    @ServiceMethod(returns = ReturnType.COLLECTION)
     public PollerFlux<PhoneNumberSearch, PhoneNumberSearch> beginCreateSearch(
         CreateSearchOptions options, Duration pollInterval) {
         Objects.requireNonNull(options, "'options' cannot be null.");
@@ -786,8 +787,8 @@ public PollerFlux<PhoneNumberSearch, PhoneNumberSearch> beginCreateSearch(
             createSearchFetchResultOperation());
     }
 
-    private Function<PollingContext<PhoneNumberSearch>, 
-        Mono<PhoneNumberSearch>> createSearchActivationOperation(CreateSearchOptions options) {
+    private Function<PollingContext<PhoneNumberSearch>, Mono<PhoneNumberSearch>> 
+        createSearchActivationOperation(CreateSearchOptions options) {
         return (pollingContext) -> {
             Mono<PhoneNumberSearch> response = createSearch(options).flatMap(createSearchResponse -> {
                 String searchId = createSearchResponse.getSearchId();
@@ -829,8 +830,8 @@ Mono<PollResponse<PhoneNumberSearch>>> createSearchPollOperation() {
     }
 
     private BiFunction<PollingContext<PhoneNumberSearch>,
-        PollResponse<PhoneNumberSearch>,
-        Mono<PhoneNumberSearch>> cancelSearchOperation() {
+        PollResponse<PhoneNumberSearch>,Mono<PhoneNumberSearch>> 
+        cancelSearchOperation() {
         return (pollingContext, firstResponse) -> {
             cancelSearch(pollingContext.getActivationResponse().getValue().getSearchId());
             return Mono.just(new PhoneNumberSearch());

diff --git a/...dministration/src/main/java/com/azure/communication/administration/PhoneNumberClient.java b/...dministration/src/main/java/com/azure/communication/administration/PhoneNumberClient.java
@@ -530,13 +530,13 @@ public Response<Void> purchaseSearchWithResponse(String searchId, Context contex
      * This function returns a Long Running Operation poller.
      * 
      * @param options A {@link CreateSearchOptions} with the search options
-     * @param lroDuration The time our long running operation will keep on polling 
+     * @param pollInterval The time our long running operation will keep on polling 
      * until it gets a result from the server
      * @return A {@link SyncPoller} object with the search result
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     public SyncPoller<PhoneNumberSearch, PhoneNumberSearch> beginCreateSearch(
-        CreateSearchOptions options, Duration lroDuration) {
-        return phoneNumberAsyncClient.beginCreateSearch(options, lroDuration).getSyncPoller();
+        CreateSearchOptions options, Duration pollInterval) {
+        return phoneNumberAsyncClient.beginCreateSearch(options, pollInterval).getSyncPoller();
     }
 }