Size: a a a
IS
dispatchFakeEvent, точнее он есть по пути @angular/cdk/testing/testbed/fake-events но тесты его не видятVM
AO
new Observable((subscriber) => {
subscriber.next();
subscriber.complete();
});
просто of() не подходит, потому что в подписке не триггерится next, только complete. of(undefined) работает правильно, но выглядит странновато. есть ещё варианты?R
NK
new Observable((subscriber) => {
subscriber.next();
subscriber.complete();
});
просто of() не подходит, потому что в подписке не триггерится next, только complete. of(undefined) работает правильно, но выглядит странновато. есть ещё варианты?AO
МС
new Observable((subscriber) => {
subscriber.next();
subscriber.complete();
});
просто of() не подходит, потому что в подписке не триггерится next, только complete. of(undefined) работает правильно, но выглядит странновато. есть ещё варианты?МС
S
new Observable((subscriber) => {
subscriber.next();
subscriber.complete();
});
просто of() не подходит, потому что в подписке не триггерится next, только complete. of(undefined) работает правильно, но выглядит странновато. есть ещё варианты?S
NK
new Observable((subscriber) => {
subscriber.next();
subscriber.complete();
});
просто of() не подходит, потому что в подписке не триггерится next, только complete. of(undefined) работает правильно, но выглядит странновато. есть ещё варианты?NK
A
function timer<T>(
fn: () => T,
time: number,
scheduler: SchedulerLike
): Observable<T> {
// Write your solution code here
return new Observable((observer) => {
return scheduler.schedule(dispatch, time, { value: fn(), period: 0, observer});
});
}
function dispatch(this, state) {
const { value, period, observer } = state;
observer.next(value);
observer.complete();
}
AO
tap и переключить поток через switchMap. соответственно, попадание в next callback критичноnew Observable слишком раздутый, а of(undefined) странненький)NK
function timer<T>(
fn: () => T,
time: number,
scheduler: SchedulerLike
): Observable<T> {
// Write your solution code here
return new Observable((observer) => {
return scheduler.schedule(dispatch, time, { value: fn(), period: 0, observer});
});
}
function dispatch(this, state) {
const { value, period, observer } = state;
observer.next(value);
observer.complete();
}
AO
AO
A
S
tap и переключить поток через switchMap. соответственно, попадание в next callback критичноnew Observable слишком раздутый, а of(undefined) странненький)С