TheMcMurder · December 31, 2019 22:28
diff --git a/index.html b/index.html
 <!DOCTYPE html>
 <html>
  <head>
    <meta charset="utf-8" />
    <meta name="viewport" content="width=device-width" />
    <title></title>
    <script src='https://cdn.jsdelivr.net/npm/[email protected]/dist/system.js'></script>
    <script src='https://cdn.jsdelivr.net/npm/[email protected]/dist/extras/amd.js'></script>
    <script src='https://cdn.jsdelivr.net/npm/[email protected]/dist/extras/named-exports.js'></script>
    <script src='https://cdn.jsdelivr.net/npm/[email protected]/dist/extras/named-register.js'></script>
    <script src='https://cdn.jsdelivr.net/npm/[email protected]/dist/extras/use-default.js'></script>
  </head>
  <body>
    <script type="systemjs-importmap">
      {"imports":{"rxjs":"https://cdn.jsdelivr.net/npm/@reactivex/[email protected]/dist/global/rxjs.umd.js"}}
    </script>
    <script>
      // rxjs hack
      const originalResolve = System.resolve

      System.resolve = function (name) {
        if (name === 'rxjs/operators') {
          return 'rxjs-operators.js'
        } else {
          return originalResolve.apply(this, arguments)
        }
      }

      System.register('rxjs-operators.js', [], _export => {
        System.import('rxjs').then(rxjs => {
          _export(rxjs.operators)
        })
        return {}
      })
    </script>
    <div>
      <button onClick='workingStream()'>Trigger observable stream</button>
    </div>
  </body>
  <script>
    function workingStream() {
      Promise.all([
        System.import('rxjs'),
        System.import('rxjs/operators')
      ]).then(([rxjs, operators]) => {
          const sub = rxjs.interval(1000).pipe(
            operators.tap((v) => console.log('v', v)),
            operators.finalize(() => {
              console.log('************************')
              console.log('finalize called')
              console.log('************************')
            })
          ).subscribe()

          setTimeout(() => {
            console.log('trigger unsubscribe on failing stream')
            sub.unsubscribe()
          }, 3000)
        }
      )
    }
  </script>

 </html>
	<!DOCTYPE html>
	<html>
	<head>
	<meta charset="utf-8" />
	<meta name="viewport" content="width=device-width" />
	<title></title>
	<script src='https://cdn.jsdelivr.net/npm/[email protected]/dist/system.js'></script>
	<script src='https://cdn.jsdelivr.net/npm/[email protected]/dist/extras/amd.js'></script>
	<script src='https://cdn.jsdelivr.net/npm/[email protected]/dist/extras/named-exports.js'></script>
	<script src='https://cdn.jsdelivr.net/npm/[email protected]/dist/extras/named-register.js'></script>
	<script src='https://cdn.jsdelivr.net/npm/[email protected]/dist/extras/use-default.js'></script>
	</head>
	<body>
	<script type="systemjs-importmap">
	{"imports":{"rxjs":"https://cdn.jsdelivr.net/npm/@reactivex/[email protected]/dist/global/rxjs.umd.js"}}
	</script>
	<script>
	// rxjs hack
	const originalResolve = System.resolve

	System.resolve = function (name) {
	if (name === 'rxjs/operators') {
	return 'rxjs-operators.js'
	} else {
	return originalResolve.apply(this, arguments)
	}
	}

	System.register('rxjs-operators.js', [], _export => {
	System.import('rxjs').then(rxjs => {
	_export(rxjs.operators)
	})
	return {}
	})
	</script>
	<div>
	<button onClick='workingStream()'>Trigger observable stream</button>
	</div>
	</body>
	<script>
	function workingStream() {
	Promise.all([
	System.import('rxjs'),
	System.import('rxjs/operators')
	]).then(([rxjs, operators]) => {
	const sub = rxjs.interval(1000).pipe(
	operators.tap((v) => console.log('v', v)),
	operators.finalize(() => {
	console.log('************************')
	console.log('finalize called')
	console.log('************************')
	})
	).subscribe()

	setTimeout(() => {
	console.log('trigger unsubscribe on failing stream')
	sub.unsubscribe()
	}, 3000)
	}
	)
	}
	</script>

	</html>