|
|
@ -88,12 +88,11 @@ export class ListService<QueryParamsType = ABP.PageQueryParams> implements OnDes
|
|
|
|
|
|
|
|
|
|
|
|
get = () => {
|
|
|
|
get = () => {
|
|
|
|
this.resetPageWhenUnchanged();
|
|
|
|
this.resetPageWhenUnchanged();
|
|
|
|
this._query$.next(({
|
|
|
|
this.next();
|
|
|
|
filter: this._filter || undefined,
|
|
|
|
};
|
|
|
|
maxResultCount: this._maxResultCount,
|
|
|
|
|
|
|
|
skipCount: this._page * this._maxResultCount,
|
|
|
|
getWithoutPageReset = () => {
|
|
|
|
sorting: this._sortOrder ? `${this._sortKey} ${this._sortOrder}` : undefined,
|
|
|
|
this.next();
|
|
|
|
} as any) as QueryParamsType);
|
|
|
|
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
private delay: MonoTypeOperatorFunction<QueryParamsType>;
|
|
|
|
private delay: MonoTypeOperatorFunction<QueryParamsType>;
|
|
|
@ -130,6 +129,15 @@ export class ListService<QueryParamsType = ABP.PageQueryParams> implements OnDes
|
|
|
|
this._skipCount = 0;
|
|
|
|
this._skipCount = 0;
|
|
|
|
} else this._skipCount = skipCount;
|
|
|
|
} else this._skipCount = skipCount;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private next() {
|
|
|
|
|
|
|
|
this._query$.next(({
|
|
|
|
|
|
|
|
filter: this._filter || undefined,
|
|
|
|
|
|
|
|
maxResultCount: this._maxResultCount,
|
|
|
|
|
|
|
|
skipCount: this._page * this._maxResultCount,
|
|
|
|
|
|
|
|
sorting: this._sortOrder ? `${this._sortKey} ${this._sortOrder}` : undefined,
|
|
|
|
|
|
|
|
} as any) as QueryParamsType);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
export type QueryStreamCreatorCallback<T, QueryParamsType = ABP.PageQueryParams> = (
|
|
|
|
export type QueryStreamCreatorCallback<T, QueryParamsType = ABP.PageQueryParams> = (
|
|
|
|