forked from cybrespace/pinafore
refactor
This commit is contained in:
parent
cfb8e28fcc
commit
cf2b6bfe2f
|
@ -7,6 +7,8 @@ import uniqBy from 'lodash/uniqBy'
|
||||||
import uniq from 'lodash/uniq'
|
import uniq from 'lodash/uniq'
|
||||||
import { isMobile } from '../_utils/isMobile'
|
import { isMobile } from '../_utils/isMobile'
|
||||||
|
|
||||||
|
const STREAMING_THROTTLE_DELAY = 3000
|
||||||
|
|
||||||
function getExistingItemIdsSet (instanceName, timelineName) {
|
function getExistingItemIdsSet (instanceName, timelineName) {
|
||||||
let timelineItemIds = store.getForTimeline(instanceName, timelineName, 'timelineItemIds') || []
|
let timelineItemIds = store.getForTimeline(instanceName, timelineName, 'timelineItemIds') || []
|
||||||
return new Set(timelineItemIds)
|
return new Set(timelineItemIds)
|
||||||
|
@ -75,7 +77,7 @@ const lazilyProcessFreshUpdates = throttle((instanceName, timelineName) => {
|
||||||
runTask(() => {
|
runTask(() => {
|
||||||
/* no await */ processFreshUpdates(instanceName, timelineName)
|
/* no await */ processFreshUpdates(instanceName, timelineName)
|
||||||
})
|
})
|
||||||
}, 3000)
|
}, STREAMING_THROTTLE_DELAY)
|
||||||
|
|
||||||
export function addStatusOrNotification (instanceName, timelineName, newStatusOrNotification) {
|
export function addStatusOrNotification (instanceName, timelineName, newStatusOrNotification) {
|
||||||
addStatusesOrNotifications(instanceName, timelineName, [newStatusOrNotification])
|
addStatusesOrNotifications(instanceName, timelineName, [newStatusOrNotification])
|
||||||
|
|
Loading…
Reference in New Issue