|
|
@ -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> = ( |
|
|
|