@internal
(scope: object)
| 220 | |
| 221 | /** @internal */ |
| 222 | private render<T>(scope: object): OperatorFunction<RxNotification<T>, T> { |
| 223 | return (o$) => |
| 224 | o$.pipe( |
| 225 | withLatestFrom(this.strategyHandler.strategy$), |
| 226 | switchMap(([notification, strategy]) => |
| 227 | this.strategyProvider.schedule( |
| 228 | () => { |
| 229 | strategy.work(this.cdRef, scope); |
| 230 | return notification.value; |
| 231 | }, |
| 232 | { |
| 233 | scope, |
| 234 | strategy: strategy.name, |
| 235 | patchZone: this.patchZone, |
| 236 | } |
| 237 | ) |
| 238 | ) |
| 239 | ); |
| 240 | } |
| 241 | |
| 242 | /** @internal */ |
| 243 | private hasInitialValue(value$: Observable<unknown>): Observable<boolean> { |
no test coverage detected