lxchurbakov · July 12, 2020 11:42
diff --git a/index.html b/index.html
 <!DOCTYPE html>
 <html>
  <head>
    <script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.6.0/rxjs.umd.js"></script>
  </head>

  <body>
    <input id="name" />
    <div id="gender">Gender: null</div>

    <script>
      const { mergeMap, map } = rxjs.operators

      const nameSubject = new rxjs.Subject()
      const genderSubject = new rxjs.Subject()

      const input  = document.getElementById('name')
      const gender = document.getElementById('gender')

      /* Put name from input to nameSubject */
      rxjs.fromEvent(input, 'input').pipe(map((e) => e.target.value)).subscribe(nameSubject)

      /* Get gender and put it to genderSubject */
      nameSubject.pipe(mergeMap((name) => new rxjs.Observable((observer) => {
        fetch(`https://api.genderize.io?name=${name}`).then(async (res) => {
          observer.next((await res.json()).gender)
          observer.complete()
        }).catch((err) => {
          observer.error(err)
        })
      }))).subscribe(genderSubject)

      /* Map genderSubject to div */
      genderSubject.subscribe({
        next: (value) => gender.innerText = `Gender: ${value}`,
      })
    </script>
  </body>
 </html>
	<!DOCTYPE html>
	<html>
	<head>
	<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.6.0/rxjs.umd.js"></script>
	</head>

	<body>
	<input id="name" />
	<div id="gender">Gender: null</div>

	<script>
	const { mergeMap, map } = rxjs.operators

	const nameSubject = new rxjs.Subject()
	const genderSubject = new rxjs.Subject()

	const input = document.getElementById('name')
	const gender = document.getElementById('gender')

	/* Put name from input to nameSubject */
	rxjs.fromEvent(input, 'input').pipe(map((e) => e.target.value)).subscribe(nameSubject)

	/* Get gender and put it to genderSubject */
	nameSubject.pipe(mergeMap((name) => new rxjs.Observable((observer) => {
	fetch(`https://api.genderize.io?name=${name}`).then(async (res) => {
	observer.next((await res.json()).gender)
	observer.complete()
	}).catch((err) => {
	observer.error(err)
	})
	}))).subscribe(genderSubject)

	/* Map genderSubject to div */
	genderSubject.subscribe({
	next: (value) => gender.innerText = `Gender: ${value}`,
	})
	</script>
	</body>
	</html>