All files / Api/Concurrency connectConcurrencyApiSubscriptions.js

1
2
3
4
5
6
7
8
9
10
11
12
1x
1x
 
5x
 
 
 
 
 
 
 
 
import createConcurrencyIntervalStream from './Streams/createConcurrencyIntervalStream';
import subscribeToConcurrencyInterval from './Subscribers/subscribeToConcurrencyInterval';
 
const connectConcurrencyApiSubscriptions = middleware => [
    subscribeToConcurrencyInterval(
        createConcurrencyIntervalStream(middleware.state.stores.concurrency.update$),
        middleware.apiServices.concurrency.request$,
    ),
];
 
export default connectConcurrencyApiSubscriptions;