fix(core): update

This commit is contained in:
2020-07-12 01:53:32 +00:00
parent 037e33caee
commit 610c1d6beb
7 changed files with 7220 additions and 773 deletions

View File

@@ -8,19 +8,19 @@ export class ObservableIntake<T> {
public completed: Promise<void>;
private completedDeffered: plugins.smartpromise.Deferred<void>;
private observableFunctions: any = {
next: payloadArg => {
next: (payloadArg) => {
// nothing
},
complete: payloadArg => {
complete: (payloadArg) => {
// nothing
}
},
};
private generator = null;
private buffered = false;
private payloadBuffer = [];
constructor() {
this.observable = plugins.rxjs.Observable.create(observerArg => {
this.observable = plugins.rxjs.Observable.create((observerArg) => {
this.observableFunctions.next = (...args) => {
return observerArg.next(...args);
};