GitHub
Twittercan-define-stream-kefir
Export a function that takes a can-define/map/map or can-define/list/list constructor and uses can-stream-kefir to create streamable properties.
canDefineStreamKefir(DefineMap)
The can-define-stream-kefir module exports a function that will take a DefineMap or DefineList constructor and add the following methods using the can-stream-kefir stream implementation:
- .toStream(observable, propAndOrEvent[,event])
- .toStreamFromProperty(property)
- .toStreamFromEvent(property)
- .toCompute(makeStream(setStream), context):compute
var canDefineStreamKefir = require("can-define-stream-kefir");
var DefineMap = require("can-define/map/map");
var Person = DefineMap.extend({
first: "string",
last: "string",
fullName: {
get: function() {
return this.first + " " + this.last;
}
},
fullNameChangeCount: {
stream: function() {
return this.toStream(".fullName").scan(function(last) {
return last + 1;
}, 0);
}
}
});
canDefineStreamKefir(Person);
var me = new Person({name: "Justin", last: "Meyer"});
me.on("fullNameChangeCount", function(ev, newVal) {
console.log(newVal);
});
me.fullNameChangeCount //-> 0
me.first = "Obaid"; //-> console.logs 1
me.last = "Ahmed"; //-> console.logs 2
Usage
For example:
Update map property based on stream value
var DefineMap = require('can-define/map/map');
var canDefineStreamKefir = require("can-define-stream-kefir");
var Person = DefineMap.extend({
name: "string",
lastValidName: {
stream: function() {
return this.toStream(".name").filter(function(name) { // Using prop name
return name.indexOf(" ") >= 0;
});
}
}
});
canDefineStreamKefir(Person);
var me = new Person({name: "James"});
me.on("lastValidName", function(lastValid) {});
me.name = "JamesAtherton"; //lastValidName -> undefined
me.name = "James Atherton"; //lastValidName -> James Atherton
Stream on DefineList
var DefineList = require('can-define/list/list');
var canDefineStreamKefir = require("can-define-stream-kefir");
var PeopleList = DefineList.extend({});
canDefineStreamKefir(PeopleList);
var people = new PeopleList([
{ first: "Justin", last: "Meyer" },
{ first: "Paula", last: "Strozak" }
]);
var stream = people.toStream('length'); // Using event name
stream.onValue(function(val) {
val //-> 2, 3
});
people.push({
first: 'Obaid',
last: 'Ahmed'
}); //-> stream.onValue -> 3