{"id":8306,"date":"2024-02-28T17:08:43","date_gmt":"2024-02-28T16:08:43","guid":{"rendered":"https:\/\/solidt.eu\/site\/?p=8306"},"modified":"2024-02-28T17:08:45","modified_gmt":"2024-02-28T16:08:45","slug":"rxjs-nested-subscribers-with-the-last-subscriber-active","status":"publish","type":"post","link":"https:\/\/solidt.eu\/site\/rxjs-nested-subscribers-with-the-last-subscriber-active\/","title":{"rendered":"RXJS Nested subscribers with the last subscriber active"},"content":{"rendered":"\n<div style=\"height: 250px; position:relative; margin-bottom: 50px;\" class=\"wp-block-simple-code-block-ace\"><pre class=\"wp-block-simple-code-block-ace\" style=\"position:absolute;top:0;right:0;bottom:0;left:0\" data-mode=\"typescript\" data-theme=\"monokai\" data-fontsize=\"14\" data-lines=\"Infinity\" data-showlines=\"true\" data-copy=\"false\">import { Subject, BehaviorSubject, Observable } from 'rxjs';\r\nimport { switchMap } from 'rxjs\/operators';\r\n\r\n\/\/ Een Subject om nieuwe subscribers te registreren\r\nconst subscriberSubject = new Subject&lt;Observable&lt;any>>();\r\n\r\n\/\/ Een BehaviorSubject om de laatste Observable te houden\r\nconst lastObservableSubject = new BehaviorSubject&lt;Observable&lt;any>>(null);\r\n\r\n\/\/ Subscribe op de subject die nieuwe subscribers registreert\r\nsubscriberSubject.pipe(\r\n  switchMap(obs => {\r\n    \/\/ Zodra er een nieuwe subscriber komt, update de laatste Observable\r\n    lastObservableSubject.next(obs);\r\n    \/\/ Return de Observable voor deze subscriber\r\n    return obs;\r\n  })\r\n).subscribe();\r\n\r\n\/\/ Functie om een nieuwe Observable te registreren\r\nfunction registerObservable(obs: Observable&lt;any>) {\r\n  subscriberSubject.next(obs);\r\n}\r\n\r\n\/\/ Externe Observable die verandert\r\nlet externalObservable = new Observable&lt;number>(observer => {\r\n  let count = 0;\r\n  const interval = setInterval(() => {\r\n    observer.next(count++);\r\n    if (count > 5) {\r\n      clearInterval(interval);\r\n      observer.complete();\r\n    }\r\n  }, 1000);\r\n});\r\n\r\n\/\/ Voorbeeld van het gebruik:\r\nregisterObservable(externalObservable);\r\n\r\n\/\/ Simuleer 3 subscriptions die op verschillende tijden worden gedaan\r\nconst subscription1 = lastObservableSubject.subscribe(value => {\r\n  console.log(\"Subscriber 1 received:\", value);\r\n});\r\n\r\nconst subscription2 = lastObservableSubject.subscribe(value => {\r\n  console.log(\"Subscriber 2 received:\", value);\r\n});\r\n\r\nconst subscription3 = lastObservableSubject.subscribe(value => {\r\n  console.log(\"Subscriber 3 received:\", value);\r\n});\r\n\r\n\/\/ Simuleer dat 'subscriber 3' na 3 seconden unsubscribed wordt\r\nsetTimeout(() => {\r\n  console.log(\"Unsubscribing 'Subscriber 3'...\");\r\n  subscription3.unsubscribe();\r\n}, 3000);\r\n<\/pre><\/div>\n","protected":false},"excerpt":{"rendered":"","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"inline_featured_image":false,"footnotes":""},"categories":[1],"tags":[],"class_list":["post-8306","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"_links":{"self":[{"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/posts\/8306","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/comments?post=8306"}],"version-history":[{"count":1,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/posts\/8306\/revisions"}],"predecessor-version":[{"id":8307,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/posts\/8306\/revisions\/8307"}],"wp:attachment":[{"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/media?parent=8306"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/categories?post=8306"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/solidt.eu\/site\/wp-json\/wp\/v2\/tags?post=8306"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}