Антон Швец

combineLatest([o1, o2, o3])
combineLatest({
  o1: o1$,
  o2: o2$,
})

keys$.pipe(
 withLatest(tank$),
 withLatest(canvasSizes$), 
)

merge(...[o1$, o2$, o$].map((o, i) => o.pipe(mark(i)))

Как при combineLatest но он дает последние значения а мне нужно null

- если запрос длится более 500 мс, то показываем лоадер
- если лоадер уже показан, то отображать его не менее 300 мс

this.postService.getPostByName(name).pipe(
  mergeMap(post => forkJoin([
    of(post),
    this.postService.getTagsByPostId(post.id),
    iif(() => post.hasComments(), this.getCommentsByPostId(post.id), of(null)),
  ]))
)
  .subscribe(([post, tags, comments]) => {...})

reloadGameInfo = interval(10000);
stepTimer = interval(1000);
second_to_event = 100;

this.stepTimer.subscribe(() => {
  this.second_to_event = this.second_to_event >= 0 ? this.second_to_event - 1 : 0;
  if (this.second_to_event === 0) {
    // make request at second_to_event equals to 0 and set second_to_event if request success
  }
});

this.reloadGameInfo.pipe(
  filter(() => this.second_to_event > 0
)
  .subscribe(() => {
    // do 10000 periodic task
  })

@Injectable({
    providedIn: 'root',
 })
 export class MyService {
  public myVar$ = new Subject();
 }

export class Comp1Component {
  constructor(
    public myService: MyService
  ) {}
}

export class Comp2Component {
  constructor(
    public myService: MyService
  ) {}
  myFunc(){
  this.myService.myVar$.next(1000);
  }
  
}

import { debounceTime } from 'rxjs/operators';
//.....
.pipe(
  debounceTime(100)
)
//.....