Skip to content

Commit

Permalink
Change mechanism back to throttle, increase delay
Browse files Browse the repository at this point in the history
  • Loading branch information
arnautov-anton committed Dec 13, 2023
1 parent 8282956 commit 376d7b7
Showing 1 changed file with 12 additions and 10 deletions.
22 changes: 12 additions & 10 deletions src/components/MessageInput/hooks/useUserTrigger.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { useCallback } from 'react';
import debounce from 'lodash.debounce';
import throttle from 'lodash.throttle';

import { SearchLocalUserParams, searchLocalUsers } from './utils';

Expand All @@ -25,7 +25,7 @@ export type UserTriggerParams<
useMentionsTransliteration?: boolean;
};

const DEBOUNCE_DELAY = 200;
const THROTTLE_DELAY = 500;

export const useUserTrigger = <
StreamChatGenerics extends DefaultStreamChatGenerics = DefaultStreamChatGenerics
Expand Down Expand Up @@ -63,8 +63,8 @@ export const useUserTrigger = <
return Object.values(uniqueUsers);
}, [members, watchers]);

const queryMembersDebounced = useCallback(
debounce(
const queryMembersThrottled = useCallback(
throttle(
async (query: string, onReady: (users: UserResponse<StreamChatGenerics>[]) => void) => {
try {
// @ts-expect-error
Expand All @@ -85,13 +85,14 @@ export const useUserTrigger = <
console.log({ error });
}
},
DEBOUNCE_DELAY,
THROTTLE_DELAY,
{ leading: true, trailing: true },
),
[channel],
);

const queryUsersDebounced = useCallback(
debounce(
const queryUsersThrottled = useCallback(
throttle(
async (query: string, onReady: (users: UserResponse<StreamChatGenerics>[]) => void) => {
if (!query) return;

Expand All @@ -114,7 +115,8 @@ export const useUserTrigger = <
console.log({ error });
}
},
DEBOUNCE_DELAY,
THROTTLE_DELAY,
{ leading: true, trailing: true },
),
[client, mentionQueryParams],
);
Expand All @@ -138,7 +140,7 @@ export const useUserTrigger = <
if (disableMentions) return;

if (mentionAllAppUsers) {
return queryUsersDebounced(query, (data: UserResponse<StreamChatGenerics>[]) =>
return queryUsersThrottled(query, (data: UserResponse<StreamChatGenerics>[]) =>
onReady?.(filterMutes(data, text), query),
);
}
Expand Down Expand Up @@ -168,7 +170,7 @@ export const useUserTrigger = <
return onReady?.(filterMutes(data, text), query);
}

queryMembersDebounced(query, (data: UserResponse<StreamChatGenerics>[]) =>
queryMembersThrottled(query, (data: UserResponse<StreamChatGenerics>[]) =>
onReady?.(filterMutes(data, text), query),
);
},
Expand Down

0 comments on commit 376d7b7

Please sign in to comment.