|
|
|
@ -956,11 +956,15 @@ export class WidgetComponent extends PageComponent implements OnInit, AfterViewI |
|
|
|
this.widgetContext.hiddenData = subscription.hiddenData; |
|
|
|
this.widgetContext.timeWindow = subscription.timeWindow; |
|
|
|
this.widgetContext.defaultSubscription = subscription; |
|
|
|
createSubscriptionSubject.next(); |
|
|
|
createSubscriptionSubject.complete(); |
|
|
|
this.ngZone.run(() => { |
|
|
|
createSubscriptionSubject.next(); |
|
|
|
createSubscriptionSubject.complete(); |
|
|
|
}); |
|
|
|
}, |
|
|
|
(err) => { |
|
|
|
createSubscriptionSubject.error(err); |
|
|
|
this.ngZone.run(() => { |
|
|
|
createSubscriptionSubject.error(err); |
|
|
|
}); |
|
|
|
} |
|
|
|
); |
|
|
|
} else if (this.widget.type === widgetType.rpc) { |
|
|
|
@ -1013,11 +1017,15 @@ export class WidgetComponent extends PageComponent implements OnInit, AfterViewI |
|
|
|
this.createSubscription(options).subscribe( |
|
|
|
(subscription) => { |
|
|
|
this.widgetContext.defaultSubscription = subscription; |
|
|
|
createSubscriptionSubject.next(); |
|
|
|
createSubscriptionSubject.complete(); |
|
|
|
this.ngZone.run(() => { |
|
|
|
createSubscriptionSubject.next(); |
|
|
|
createSubscriptionSubject.complete(); |
|
|
|
}); |
|
|
|
}, |
|
|
|
(err) => { |
|
|
|
createSubscriptionSubject.error(err); |
|
|
|
this.ngZone.run(() => { |
|
|
|
createSubscriptionSubject.error(err); |
|
|
|
}); |
|
|
|
} |
|
|
|
); |
|
|
|
this.detectChanges(); |
|
|
|
|