@@ -936,7 +936,7 @@ export class Gpio extends ConfigItem {
936
936
let pinId = ( typeof data . pinId !== 'undefined' ) ? parseInt ( data . pinId , 10 ) : undefined ;
937
937
let dev = this . pins . getItemById ( pinId ) ;
938
938
await dev . setDeviceFeed ( data ) ;
939
- dev . initFeeds ( ) ;
939
+ // dev.initFeeds();
940
940
return Promise . resolve ( dev . feeds ) ;
941
941
}
942
942
catch ( err ) { return Promise . reject ( err ) ; }
@@ -948,7 +948,7 @@ export class Gpio extends ConfigItem {
948
948
let devId = ( typeof data . pinId !== 'undefined' ) ? parseInt ( data . pinId , 10 ) : undefined ;
949
949
let dev = this . pins . getItemById ( devId ) ;
950
950
await dev . deleteDeviceFeed ( data ) ;
951
- dev . initFeeds ( ) ;
951
+ // dev.initFeeds();
952
952
return Promise . resolve ( dev . feeds ) ;
953
953
}
954
954
catch ( err ) { return Promise . reject ( err ) ; }
@@ -1082,19 +1082,23 @@ export class GpioPin extends ConfigItem {
1082
1082
resolve ( this ) ;
1083
1083
} )
1084
1084
}
1085
- public _feeds : Feed [ ] = [ ] ;
1085
+ /* public _feeds: Feed[] = [];
1086
1086
public initFeeds() {
1087
1087
this._feeds = [];
1088
1088
for (let i = 0; i < this.feeds.length; i++) {
1089
1089
let f = this.feeds.getItemByIndex(i);
1090
1090
this._feeds.push(new Feed(f));
1091
1091
}
1092
- }
1092
+ } */
1093
1093
public async emitFeeds ( ) {
1094
1094
try {
1095
- for ( let i = 0 ; i < this . _feeds . length ; i ++ ) {
1096
- await this . _feeds [ i ] . send ( this ) ;
1095
+ for ( let i = 0 ; i < this . feeds . length ; i ++ ) {
1096
+ let feed = new Feed ( this . feeds . getItemByIndex ( i ) ) ;
1097
+ await feed . send ( this ) ;
1097
1098
}
1099
+ // for (let i = 0; i < this._feeds.length; i++) {
1100
+ // await this._feeds[i].send(this);
1101
+ // }
1098
1102
} catch ( err ) { logger . error ( err ) ; }
1099
1103
}
1100
1104
public getExtended ( ) {
0 commit comments