example service

example.service.ts

@Injectable()
export class ProductsService {

  private readonly stuff$ = new ReplaySubject<Stuff[]>();
  readonly stuff = this.stuff$.asObservable();

  constructor(private readonly fire: Fire) {
    this.fire.getTheStuff().subscribe(
      (stuff) => this.stuff$.next(stuff)
    );
  }
}