How to use the rx-extensions.getMany function in rx-extensions
To help you get started, we’ve selected a few rx-extensions examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
noobaa / noobaa-core / frontend / src / app / components / modals / add-bucket-trigger-modal / add-bucket-trigger-modal.js View on Github 
constructor({ bucketName }) {
super();
this.bucketName = ko.unwrap(bucketName);
this.observe(
state$.pipe(
getMany(
['buckets', this.bucketName, 'triggers'],
'functions',
'accounts'
)
),
this.onState
);
}this.breadcrumbs = ko.observableArray();
this.area = ko.observable();
this.panel = ko.observable();
this.isUploadButtonVisible = ko.observable(false);
this.observe(
state$.pipe(getMany(
'location',
'session'
)),
this.onLocation
);
this.observe(
state$.pipe(
getMany(
'accounts',
['session', 'user']
)
),
this.onAccount
);
registerForAlerts();
}constructor({ bucketName }) {
super();
this.bucketName = ko.unwrap(bucketName);
this.observe(
state$.pipe(get('location')),
this.onLocation
);
this.observe(
state$.pipe(
getMany(
['buckets', this.bucketName],
'objects',
['session', 'user'],
['accounts'],
['system', 'sslCert', 'installed']
)
),
this.onState
);
}label: 'New Version',
value: this.stagedVersion
},
{
label: 'Validated at',
value: this.testedAt
},
{
label: 'Validation Result',
value: 'Successful'
}
];
this.observe(
state$.pipe(
getMany(
['location', 'params', 'system'],
'system',
['topology', 'servers']
)
),
this.onState
);
}constructor({ bucketName }) {
super();
this.observe(
state$.pipe(
getMany(
['buckets', ko.unwrap(bucketName)],
'hostPools'
)
),
this.onState
);
}constructor({ host }) {
super();
this.host = ko.unwrap(host);
this.observe(
state$.pipe(
getMany(
['hosts', 'items', this.host, 'services'],
['forms', this.formName]
)
),
this.onState
);
}constructor({ bucketName }) {
super();
this.bucketName = ko.unwrap(bucketName);
this.observe(
state$.pipe(
getMany(
['buckets', this.bucketName],
['forms', this.formName]
)
),
this.onState
);
}constructor({ bucket }) {
super();
this.bucketName = ko.unwrap(bucket);
this.observe(
state$.pipe(
getMany(
['namespaceBuckets', this.bucketName],
'namespaceResources',
['forms', this.formName]
)
),
this.onState
);
}constructor({ bucket }) {
super();
this.columns = columns;
this.bucketName = ko.unwrap(bucket);
this.rows = ko.observableArray();
this.stateLoaded = ko.observable();
this.observe(
state$.pipe(
getMany(
['namespaceBuckets', this.bucketName],
'namespaceResources'
)
),
this.onBucket
);
}constructor({ name }) {
super();
this.hostName = ko.unwrap(name);
this.observe(
state$.pipe(
getMany(
['hosts', 'items', this.hostName],
'location'
)
),
this.onHost
);
}rx-extensions
Library for useful RxJS extensions and operators
