Skip to content

Commit

Permalink
Generated from 50fcd80ec9967823be95716b8dfab8508f6e5ad8
Browse files Browse the repository at this point in the history
Fix additional parameter
  • Loading branch information
SDK Automation committed Sep 7, 2020
1 parent 53dee37 commit d4346fd
Show file tree
Hide file tree
Showing 5 changed files with 13 additions and 27 deletions.
6 changes: 3 additions & 3 deletions sdk/kusto/mgmt-v2020_02_15/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -11,11 +11,11 @@
<parent>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-arm-parent</artifactId>
<version>1.3.0</version>
<relativePath>../../parents/azure-arm-parent/pom.xml</relativePath>
<version>1.1.0</version>
<relativePath>../../../pom.management.xml</relativePath>
</parent>
<artifactId>azure-mgmt-kusto</artifactId>
<version>1.0.0-beta-1</version>
<version>1.0.0-beta</version>
<packaging>jar</packaging>
<name>Microsoft Azure SDK for Kusto Management</name>
<description>This package contains Microsoft Kusto Management SDK.</description>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -113,10 +113,10 @@ public PagedList<Cluster> list() {
public Observable<Cluster> listAsync() {
ClustersInner client = this.inner();
return client.listAsync()
.flatMap(new Func1<Page<ClusterInner>, Observable<ClusterInner>>() {
.flatMap(new Func1<List<ClusterInner>, Observable<ClusterInner>>() {
@Override
public Observable<ClusterInner> call(Page<ClusterInner> innerList) {
return Observable.from(innerList.items());
public Observable<ClusterInner> call(List<ClusterInner> innerList) {
return Observable.from(innerList);
}
})
.map(new Func1<ClusterInner, Cluster>() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1581,16 +1581,8 @@ private ServiceResponse<PageImpl<ClusterInner>> listByResourceGroupDelegate(Resp
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent
* @return the List&lt;ClusterInner&gt; object if successful.
*/
public PagedList<ClusterInner> list() {
PageImpl<ClusterInner> page = new PageImpl<>();
page.setItems(listWithServiceResponseAsync().toBlocking().single().body());
page.setNextPageLink(null);
return new PagedList<ClusterInner>(page) {
@Override
public Page<ClusterInner> nextPage(String nextPageLink) {
return null;
}
};
public List<ClusterInner> list() {
return listWithServiceResponseAsync().toBlocking().single().body();
}

/**
Expand All @@ -1610,12 +1602,11 @@ public ServiceFuture<List<ClusterInner>> listAsync(final ServiceCallback<List<Cl
* @throws IllegalArgumentException thrown if parameters fail the validation
* @return the observable to the List&lt;ClusterInner&gt; object
*/
public Observable<Page<ClusterInner>> listAsync() {
return listWithServiceResponseAsync().map(new Func1<ServiceResponse<List<ClusterInner>>, Page<ClusterInner>>() {
public Page<ClusterInner> call(ServiceResponse<List<ClusterInner>> response) {
PageImpl<ClusterInner> page = new PageImpl<>();
page.setItems(response.body());
return page;
public Observable<List<ClusterInner>> listAsync() {
return listWithServiceResponseAsync().map(new Func1<ServiceResponse<List<ClusterInner>>, List<ClusterInner>>() {
@Override
public List<ClusterInner> call(ServiceResponse<List<ClusterInner>> response) {
return response.body();
}
});
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,9 +13,6 @@
import com.fasterxml.jackson.annotation.JsonTypeName;
import com.fasterxml.jackson.annotation.JsonSubTypes;
import com.microsoft.azure.ProxyResource;
import com.microsoft.azure.management.kusto.v2020_02_15.EventGridDataConnection;
import com.microsoft.azure.management.kusto.v2020_02_15.EventHubDataConnection;
import com.microsoft.azure.management.kusto.v2020_02_15.IotHubDataConnection;

/**
* Class representing an data connection.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,6 @@
import com.fasterxml.jackson.annotation.JsonTypeName;
import com.fasterxml.jackson.annotation.JsonSubTypes;
import com.microsoft.azure.ProxyResource;
import com.microsoft.azure.management.kusto.v2020_02_15.ReadOnlyFollowingDatabase;
import com.microsoft.azure.management.kusto.v2020_02_15.ReadWriteDatabase;

/**
* Class representing a Kusto database.
Expand Down

0 comments on commit d4346fd

Please sign in to comment.