This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<!DOCTYPE html> | |
<html lang="en"> | |
<head> | |
<meta charset="utf-8" /> | |
<title>👨🏻🍳🅰️ Ngx Light by Younes @ Marmicode.io</title> | |
<meta name="description" content="👨🏻🍳🅰️ Ngx Light" /> | |
<meta name="viewport" content="width=device-width,initial-scale=1" /> | |
<script type="importmap"> | |
{ | |
"imports": { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<!DOCTYPE html> | |
<html lang="en"> | |
<head> | |
<meta charset="utf-8" /> | |
<title>👨🏻🍳🅰️ Ngx Light by Younes @ Marmicode.io</title> | |
<meta name="description" content="👨🏻🍳🅰️ Ngx Light" /> | |
<meta name="viewport" content="width=device-width,initial-scale=1" /> | |
<script type="importmap"> | |
{ | |
"imports": { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import * as rx from 'rxjs'; | |
const delays = [3000, 2000, 500]; | |
const switchMapOnNext = (project) => (source) => { | |
return new rx.Observable((observer) => { | |
let previousSubs = new rx.Subscription(); | |
const subscription = source.subscribe((value) => { | |
const result$ = project(value); | |
const currentPreviousSubs = previousSubs; |
OlderNewer