rxjs之ajax

rxjs.ts

import { ajax } from 'rxjs/ajax';
import { map, tap, catchError } from 'rxjs/operators';
import { Subject, of } from 'rxjs';



function request(url){
  const subject = new Subject<any>();
  setTimeout(() => {
  if(localStorage.getItem(url)){
      console.log('localStorage.getItem(url)');
      subject.next(JSON.parse(localStorage.getItem(url)));
    }
  }, 0)
  ajax(url).pipe(
    tap(userResponse => {
      // console.log('userResponse', userResponse);
      subject.next(userResponse);
      localStorage.setItem(url, JSON.stringify(userResponse));
    }),
    catchError(error => {
      // console.log('error: ', error);
      subject.next(error);
      return of(error);
    })
  ).subscribe();
  return subject;
}

const obs$ = request(`https://api.github.com/users?per_page=5`);
const obs2$ = request(`https://api.github.com/users?per_page=1`);


obs$.subscribe(data => {
  console.log('main1', data)
})

// obs2$.subscribe(data => {
//   console.log('main2', data)
// })