Reactive advanced architecture programming with @rxdi/core and rxjs

advanced-architecture-reactive

import { setup } from '@rxdi/core';
import { switchMap } from 'rxjs/operators';
import { combineLatest } from 'rxjs';

setup({
  services: [
    {
      provide: 'gosho',
      lazy: true,
      useFactory: async () => 'yey'
    }
  ]
})
  .pipe(
    switchMap(ctx =>
      combineLatest(
        setup({
          services: [
            {
              provide: 'pesho',
              useFactory: () => ctx.get('gosho')
            }
          ]
        }),
        setup({
          services: []
        }),
        setup({
          services: []
        }),
        setup({
          services: []
        })
      )
    )
  )
  .subscribe(ctx => {
    console.log(ctx.get('pesho'));
  });

import { setup } from '@rxdi/core';
import { switchMap } from 'rxjs/operators';
import { combineLatest } from 'rxjs';

setup({
  services: [
    {
      provide: 'gosho',
      lazy: true,
      useFactory: async () => 'yey'
    }
  ]
})
  .pipe(
    switchMap(ctx =>
      combineLatest(
        setup({
          services: [
            {
              provide: 'pesho',
              useFactory: () => ctx.get('gosho')
            }
          ]
        }),
        setup({
          services: []
        }),
        setup({
          services: []
        }),
        setup({
          services: []
        })
      )
    )
  )
  .subscribe(ctx => {
    console.log(ctx.get('pesho'));
  });