Copyright (c) Microsoft Corporation. All rights reserved.
Licensed under the MIT License. See License.txt in the project root for
license information.
/**
* Copyright (c) Microsoft Corporation. All rights reserved.
* Licensed under the MIT License. See License.txt in the project root for
* license information.
*/
package com.microsoft.azure.management.monitor.implementation;
import com.google.common.base.Function;
import com.google.common.collect.Lists;
import com.microsoft.azure.management.apigeneration.LangDefinition;
import com.microsoft.azure.management.monitor.MetricDefinition;
import com.microsoft.azure.management.monitor.MetricDefinitions;
import rx.Observable;
import rx.functions.Func1;
import java.util.List;
Implementation for MetricDefinitions
. /**
* Implementation for {@link MetricDefinitions}.
*/
@LangDefinition
class MetricDefinitionsImpl
implements MetricDefinitions {
private final MonitorManager myManager;
MetricDefinitionsImpl(final MonitorManager monitorManager) {
this.myManager = monitorManager;
}
@Override
public MonitorManager manager() {
return this.myManager;
}
@Override
public MetricDefinitionsInner inner() {
return this.myManager.inner().metricDefinitions();
}
@Override
public List<MetricDefinition> listByResource(String resourceId) {
List<MetricDefinitionInner> inners = this.inner().list(resourceId);
if (inners == null) {
return null;
}
return Lists.transform(inners, new Function<MetricDefinitionInner, MetricDefinition>() {
@Override
public MetricDefinition apply(MetricDefinitionInner metricDefinitionInner) {
return new MetricDefinitionImpl(metricDefinitionInner, myManager);
}
});
}
@Override
public Observable<MetricDefinition> listByResourceAsync(String resourceId) {
return this.inner().listAsync(resourceId)
.flatMapIterable(new Func1<List<MetricDefinitionInner>, Iterable<MetricDefinitionInner>>() {
@Override
public Iterable<MetricDefinitionInner> call(List<MetricDefinitionInner> items) {
return items;
}
}).map(new Func1<MetricDefinitionInner, MetricDefinition>() {
@Override
public MetricDefinition call(MetricDefinitionInner metricDefinitionInner) {
return new MetricDefinitionImpl(metricDefinitionInner, myManager);
}
});
}
}