11import { warn } from "./util" ;
22import { Subject , Subscription , isObservable } from "rxjs" ;
33
4-
54export default {
65 created ( ) {
76 const vm = this ;
8- console . log ( this )
97 const domStreams = vm . $options . domStreams ;
108
119 if ( domStreams ) {
12- domStreams . forEach ( key => {
10+ domStreams . forEach ( ( key ) => {
1311 vm [ key ] = new Subject ( ) ;
1412 } ) ;
1513 }
1614 const observableMethods = vm . $options . observableMethods ;
1715 if ( observableMethods ) {
1816 if ( Array . isArray ( observableMethods ) ) {
19- observableMethods . forEach ( methodName => {
17+ observableMethods . forEach ( ( methodName ) => {
2018 vm [ methodName + "$" ] = vm . $createObservableMethod ( methodName ) ;
2119 } ) ;
2220 } else {
23- Object . keys ( observableMethods ) . forEach ( methodName => {
24- vm [ observableMethods [ methodName ] ] = vm . $createObservableMethod (
25- methodName
26- ) ;
21+ Object . keys ( observableMethods ) . forEach ( ( methodName ) => {
22+ vm [ observableMethods [ methodName ] ] =
23+ vm . $createObservableMethod ( methodName ) ;
2724 } ) ;
2825 }
2926 }
@@ -35,7 +32,7 @@ export default {
3532 if ( obs ) {
3633 vm . $observables = { } ;
3734 vm . _subscription = new Subscription ( ) ;
38- Object . keys ( obs ) . forEach ( key => {
35+ Object . keys ( obs ) . forEach ( ( key ) => {
3936 vm [ key ] = undefined ;
4037 const ob = ( vm . $observables [ key ] = obs [ key ] ) ;
4138 if ( ! isObservable ( ob ) ) {
@@ -49,11 +46,11 @@ export default {
4946 }
5047 vm . _subscription . add (
5148 obs [ key ] . subscribe (
52- value => {
49+ ( value ) => {
5350 vm [ key ] = value ;
54- vm = { ...vm }
51+ vm = { ...vm } ;
5552 } ,
56- error => {
53+ ( error ) => {
5754 throw error ;
5855 }
5956 )
@@ -62,10 +59,9 @@ export default {
6259 }
6360 } ,
6461
65-
6662 beforeUnmount ( ) {
6763 if ( this . _subscription ) {
6864 this . _subscription . unsubscribe ( ) ;
6965 }
70- }
66+ } ,
7167} ;
0 commit comments