Mirrors/phanpy
1
0
Fork 0
mirror of https://github.com/cheeaun/phanpy.git synced 2025-02-24 00:38:49 +01:00
Code Issues Projects Releases Packages Wiki Activity

Debounce new statuses

Browse source
This commit is contained in:
Lim Chee Aun 2023-01-01 12:01:54 +08:00
parent b153d7526c
commit 4e80e9e0cb
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/app.jsx
View file

@ -2,6 +2,7 @@ import './app.css';
import 'toastify-js/src/toastify.css'; import 'toastify-js/src/toastify.css';
import { createHashHistory } from 'history'; import { createHashHistory } from 'history';
import debounce from 'just-debounce-it';
import { login } from 'masto'; import { login } from 'masto';
import Router, { route } from 'preact-router'; import Router, { route } from 'preact-router';
import { useEffect, useLayoutEffect, useState } from 'preact/hooks'; import { useEffect, useLayoutEffect, useState } from 'preact/hooks';
@ -298,7 +299,7 @@ function App() {
async function startStream() { async function startStream() {
const stream = await masto.v1.stream.streamUser(); const stream = await masto.v1.stream.streamUser();
console.log('STREAM START', { stream }); console.log('STREAM START', { stream });
stream.on('update', (status) => { const handleNewStatus = debounce((status) => {
console.log('UPDATE', status); console.log('UPDATE', status);
const inHomeNew = states.homeNew.find((s) => s.id === status.id); const inHomeNew = states.homeNew.find((s) => s.id === status.id);
@ -315,7 +316,8 @@ async function startStream() {
if (status.reblog) { if (status.reblog) {
states.statuses.set(status.reblog.id, status.reblog); states.statuses.set(status.reblog.id, status.reblog);
} }
}); }, 5000);
stream.on('update', handleNewStatus);
stream.on('status.update', (status) => { stream.on('status.update', (status) => {
console.log('STATUS.UPDATE', status); console.log('STATUS.UPDATE', status);
states.statuses.set(status.id, status); states.statuses.set(status.id, status);