@@ -10,15 +10,14 @@ import { merge } from "rxjs/observable/merge";
1010import { initLogger , logHandler$ } from "./log" ;
1111import { effectOutputHandlers$ } from "./effects" ;
1212import { Nanologger } from "../vendor/logger" ;
13- import { scrollRestoreHandlers$ } from "./scroll-restore" ;
13+ import { scrollRestoreHandlers$ , initWindowName } from "./scroll-restore" ;
1414import { initListeners } from "./listeners" ;
1515import { groupBy } from "rxjs/operators/groupBy" ;
1616import { withLatestFrom } from "rxjs/operators/withLatestFrom" ;
1717import { mergeMap } from "rxjs/operators/mergeMap" ;
1818import { share } from "rxjs/operators/share" ;
1919import { filter } from "rxjs/operators/filter" ;
2020import { pluck } from "rxjs/operators/pluck" ;
21- import { tap } from "rxjs/operators/tap" ;
2221import { of } from "rxjs/observable/of" ;
2322
2423export interface Inputs {
@@ -35,6 +34,7 @@ export interface Inputs {
3534
3635const window$ = initWindow ( ) ;
3736const document$ = initDocument ( ) ;
37+ const names$ = initWindowName ( window ) ;
3838const { socket$, io$ } = initSocket ( ) ;
3939const option$ = initOptions ( ) ;
4040const navigator$ = of ( navigator ) ;
@@ -86,7 +86,10 @@ const output$ = getStream("[socket]", inputs)(
8686) ;
8787
8888const effect$ = getStream ( "[effect]" , inputs ) ( combinedEffectHandler$ , output$ ) ;
89- const dom$ = getStream ( "[dom-effect]" , inputs ) ( domHandlers$ , effect$ ) ;
89+ const dom$ = getStream ( "[dom-effect]" , inputs ) (
90+ domHandlers$ ,
91+ merge ( effect$ , names$ )
92+ ) ;
9093
9194const merged$ = merge ( output$ , effect$ , dom$ ) ;
9295
0 commit comments