All files / Api/UserActionsWatched connectUserActionsWatchedSubscriptions.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
1x
1x
1x
1x
 
15x
 
 
 
 
5x
 
5x
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
import createTokenUpdate from '../UserActions/Streams/createTokenUpdate';
import createWatchedEvent from './Streams/createWatchedEvent';
import subscribeToWatchedEvent from './Subscribers/subscribeToWatchedEvent';
import subscribeToUserActionsWatchedResponse from './Subscribers/subscribeToUserActionsWatchedResponse';
 
const connectUserActionsWatched = middleware => {
    const {
        asset,
        config,
        userActions,
    } = middleware.state.stores;
 
    return [
        subscribeToWatchedEvent(
            createWatchedEvent(
                createTokenUpdate(config.update$),
                userActions.update$,
                asset.update$,
                middleware.player
            ),
            middleware.apiServices.userActionsWatched.request$,
        ),
        subscribeToUserActionsWatchedResponse(
            middleware.apiServices.userActionsWatched.response$,
        ),
    ];
};
 
export default connectUserActionsWatched;