#reactive-streams code explainers

typescript

import { Component, inject } from '@angular/core';
import { combineLatest, map, startWith } from 'rxjs';
import { UserStore } from './user.store';
import { CartStore } from './cart.store';

The view model pattern in Angular

rxjs view-model reactive-streams

Intermediate 6 steps

typescript

import { Controller, Param, Sse, MessageEvent } from '@nestjs/common';
import { Observable, interval, merge } from 'rxjs';
import { filter, map, takeWhile } from 'rxjs/operators';
import { JobService } from './job.service';

Streaming job progress with SSE in NestJS

server-sent-events reactive-streams rxjs

Intermediate 8 steps

java

@RestController
@RequestMapping("/api/quotes")
public class QuoteStreamController {

Streaming market quotes with Spring WebFlux

reactive-streams backpressure server-sent-events

Advanced 9 steps