32 lines
612 B
JavaScript
32 lines
612 B
JavaScript
import s from 'apigo.cc/gojs/service'
|
|
import co from 'apigo.cc/gojs/console'
|
|
import task from 'apigo.cc/gojs/task'
|
|
|
|
function onStart() {
|
|
co.info('task start')
|
|
}
|
|
|
|
let i = 0
|
|
function onRun() {
|
|
let keys = task.keys('wsTest_')
|
|
// let connCount = s.dataCount('wsTest')
|
|
if (keys.length > 0) {
|
|
// let conns = s.dataFetch('wsTest')
|
|
let conns = task.getAll('wsTest_')
|
|
for (let id in conns) {
|
|
let conn = conns[id]
|
|
if (!conn.write(i++)) {
|
|
task.remove(id)
|
|
}
|
|
}
|
|
}
|
|
co.info('task run', keys.length)
|
|
}
|
|
|
|
|
|
function onStop() {
|
|
// s.dataRemove('wsTest')
|
|
task.removeAll('wsTest_')
|
|
co.info('task stop')
|
|
}
|