All files / Api/ResumePoints connectResumePointsApiSubscriptions.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
1x
1x
 
1x
10x
 
5x
 
 
 
 
5x
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
import createResumePointsIntervalStream from './Streams/createResumePointsIntervalStream';
import createPlaybackSeekStream from './Streams/createPlaybackSeekStream';
import createResumePointsTriggerStream from './Streams/createResumePointsTriggerStream';
import subscribeToResumePointsTrigger from './Subscribers/subscribeToResumePointsTrigger';
 
const connectResumePointsApiSubscriptions = middleware => {
    const { player, state } = middleware;
 
    middleware.apiServices.resumePoints.response$
        .subscribe(() => {
            // TODO to be added to the error handling logic
        });
 
    return [
        subscribeToResumePointsTrigger(
            createResumePointsTriggerStream(
                createResumePointsIntervalStream(
                    player.state.stores.playback.update$,
                    state.stores.resumePoints.update$
                ),
                createPlaybackSeekStream(
                    player.state.stores.playback.update$,
                    state.stores.resumePoints.update$
                ),
                state.stores.config.update$,
                state.stores.playback.update$,
                player.state.stores.playback.update$,
            ),
            middleware.apiServices.resumePoints.request$
        ),
    ];
};
 
export default connectResumePointsApiSubscriptions;