Comparing version 1.4.3 to 1.4.4
{ | ||
"name": "fastrx", | ||
"version": "1.4.3", | ||
"version": "1.4.4", | ||
"description": "fast rxjs implemention", | ||
@@ -5,0 +5,0 @@ "main": "dist/cjs.js", |
@@ -105,3 +105,3 @@ #rx4rx-fast | ||
rxComputed:{ | ||
test0:_this=>rx.interval(1000).take(10),//简单的订阅 | ||
test0:()=>rx.interval(1000).take(10),//简单的订阅 | ||
test_watch:{//使用watch触发Observable发射数据 | ||
@@ -108,0 +108,0 @@ get:ob=>ob.switchMapTo(rx.interval(1000)).map(x=>10-x) |
@@ -38,7 +38,7 @@ const { rx } = require('./index') | ||
if (typeof item == 'function') { | ||
const ob = item(this) | ||
const ob = item.call(this) | ||
this.$data._rxComputed.push(ob.subscribe(setFunc)) | ||
} else { | ||
const subject = this.$data._rxSubjects[key] | ||
this.$data._rxComputed.push(item.get(subject).subscribe(item.call ? data => this[key](data) : setFunc)) | ||
this.$data._rxComputed.push(item.get.call(this,subject).subscribe(item.call ? data => this[key](data) : setFunc)) | ||
if ('watch' in item) { | ||
@@ -45,0 +45,0 @@ if (typeof item.watch == 'object') { |
258788