All files / Player/Streams createPlayerLoadStream.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
1x
1x
 
 
 
 
 
 
 
 
 
40x
 
 
6x
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
import { withLatestFrom, map } from 'rxjs/operators';
import { zip } from 'rxjs';
 
/**
 * @param {Observable<Playback>}
 * @param {Observable<ResumePoints>}
 * @param {Observable<Config>}
 * @param {Observable<Asset>}
 * @returns {Observable<[Playback, ResumePoints, Config, Asset]>}
 */
 
const flattenStream = ([[[latestPlayback, latestResumePoints], latestConfig], latestAsset]) =>
    [latestPlayback, latestResumePoints, latestConfig, latestAsset];
 
const createPlayerLoadStream = (
    playbackUpdate$,
    resumePointsUpdate$,
    configUpdate$,
    assetUpdate$
) =>
    zip(
        playbackUpdate$,
        resumePointsUpdate$,
    )
        .pipe(
            withLatestFrom(configUpdate$),
            withLatestFrom(assetUpdate$),
            map(flattenStream)
        );
 
export {
    flattenStream,
    createPlayerLoadStream as default,
};