Fixed execution of RxJS teardown logic on complete (7.2.3 regression)

Author: squidfunk

material/assets/javascripts/bundle.9264e2c0.min.js

@@ -223,7 +223,7 @@ <h1>{{ page.title | d(config.site_name, true)}}</h1>
       </script>
     {% endblock %}
     {% block scripts %}
-      <script src="{{ 'assets/javascripts/bundle.febc23d1.min.js' | url }}"></script>
+      <script src="{{ 'assets/javascripts/bundle.9264e2c0.min.js' | url }}"></script>
       {% for path in config["extra_javascript"] %}
         <script src="{{ path | url }}"></script>
       {% endfor %}

material/assets/javascripts/bundle.febc23d1.min.js.map renamed to material/assets/javascripts/bundle.9264e2c0.min.js.map

@@ -16,5 +16,5 @@
 {% endblock %}
 {% block scripts %}
   {{ super() }}
-  <script src="{{ 'overrides/assets/javascripts/bundle.515b7185.min.js' | url }}"></script>
+  <script src="{{ 'overrides/assets/javascripts/bundle.a07ad7e8.min.js' | url }}"></script>
 {% endblock %}

material/assets/javascripts/bundle.febc23d1.min.js

@@ -31,6 +31,7 @@ import {
 } from "rxjs"
 import {
   distinctUntilKeyChanged,
+  finalize,
   map,
   switchMap,
   tap,
@@ -175,7 +176,8 @@ export function mountCodeBlock(
   /* Create and return component */
   return watchCodeBlock(el, options)
     .pipe(
-      tap(internal$),
+      tap(state => internal$.next(state)),
+      finalize(() => internal$.complete()),
       map(state => ({ ref: el, ...state }))
     )
 }

material/base.html

@@ -23,6 +23,7 @@
 import { Observable, Subject } from "rxjs"
 import {
   filter,
+  finalize,
   map,
   mapTo,
   mergeWith,
@@ -107,7 +108,8 @@ export function mountDetails(
   /* Create and return component */
   return watchDetails(el, options)
     .pipe(
-      tap(internal$),
+      tap(state => internal$.next(state)),
+      finalize(() => internal$.complete()),
       mapTo({ ref: el })
     )
 }

material/overrides/assets/javascripts/bundle.515b7185.min.js renamed to material/overrides/assets/javascripts/bundle.a07ad7e8.min.js

@@ -28,6 +28,7 @@ import {
   of
 } from "rxjs"
 import {
+  finalize,
   delay,
   map,
   observeOn,
@@ -131,7 +132,8 @@ export function mountDialog(
   /* Create and return component */
   return watchDialog(el, options)
     .pipe(
-      tap(internal$),
+      tap(state => internal$.next(state)),
+      finalize(() => internal$.complete()),
       map(state => ({ ref: el, ...state }))
     )
 }