All files / Api/Concurrency/Subscribers subscribeToConcurrencyInterval.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
6x
 
 
 
 
 
 
 
 
 
 
4x
 
1x
 
 
 
 
 
 
 
 
 
const subscribeToConcurrencyInterval = (
    concurrencyInterval$,
    concurrencyApiRequest$
) =>
    concurrencyInterval$
        .subscribe(latestConcurrency => {
            const {
                playerId,
                encryptedLock,
                lockId,
                sequenceToken,
            } = latestConcurrency;
 
            concurrencyApiRequest$.next({
                playerId,
                encryptedLock,
                lockId,
                sequenceToken,
            });
        });
 
export default subscribeToConcurrencyInterval;