// 客户端代码
export default {
data() {},
onLoad() {},
methods: {
async testSSE() {
const channel = new uniCloud.SSEChannel() // 创建消息通道
channel.on('message', (message) => { // 监听message事件
console.log('on message', message);
})
channel.on('end', (message) => { // 监听end事件，如果云端执行end时传了message，会在客户端end事件内收到传递的消息
console.log('on end', message);
})
await channel.open() // 等待通道开启
const massiveTaskObj = uniCloud.importObject('massive-task-obj')
const res = await massiveTaskObj.excuteTask({
channel: channel // 调用云对象时传入通道对象
})
}
}
}
// 云对象massive-task-obj代码
module.exports = {
excuteTask(param) {
const channel = uniCloud.deserializeSSEChannel(param.channel)
await channel.write({
a: 1
})
await channel.write({
a: 2
})
await channel.write({
a: 3
})
await channel.write({
a: 4
})
await channel.end({
a: 5
})
return {}
}
}
0 个回复