Sha256: d5f24eae0c06c78ce00a9305e9c747424c68024eee31df38fde0a9c7d824e6a5
Contents?: true
Size: 1.29 KB
Versions: 20
Compression:
Stored size: 1.29 KB
Contents
var adapter;
adapter = {
subscribe: function(record, attribute_path, callback) {
if (record == null) {
throw new TypeError('observable.adapters.rivets.subscribe: No record provided for subscription');
}
if (attribute_path) {
return record.subscribe(attribute_path, callback);
}
},
unsubscribe: function(record, attribute_path, callback) {
if (record == null) {
throw new TypeError('observable.adapters.rivets.unsubscribe: No record provided for subscription');
}
return record.unsubscribe(attribute_path, callback);
},
read: function(record, attribute_path) {
if (record == null) {
throw new TypeError('observable.adapters.rivets.read: No record provided for subscription');
}
if (attribute_path.indexOf('.') === -1) {
return record[attribute_path];
} else {
return record.observation.observers[attribute_path].value_;
}
},
publish: function(record, attribute_path, value) {
if (record == null) {
throw new TypeError('observable.adapters.rivets.publish: No record provided for subscription');
}
if (attribute_path.indexOf('.') === -1) {
return record[attribute_path] = value;
} else {
return record.observation.observers[attribute_path].setValue(value);
}
}
};
export default adapter;
Version data entries
20 entries across 18 versions & 1 rubygems