}
@Override
public CompletableFuture<StatusCode> setPublishingMode(boolean publishingEnabled) {
return client.setPublishingMode(publishingEnabled, newArrayList(subscriptionId))
.thenApply(response -> {
<BUG>StatusCode statusCode = response.getResults()[0];
</BUG>
if (statusCode.isGood()) {
setPublishingEnabled(publishingEnabled);
}

}
}
return results;
});
}
@Override
public CompletableFuture<StatusCode> setPublishingMode(boolean publishingEnabled) {
return client.setPublishingMode(publishingEnabled, newArrayList(subscriptionId))
.thenApply(response -> {
StatusCode statusCode = l(response.getResults()).get(0);
if (statusCode.isGood()) {
setPublishingEnabled(publishingEnabled);
}
