Function useInfiniteSubscription

React hook based on React Query for managing, caching and syncing observables in React with infinite pagination.

Example

function ExampleInfiniteSubscription() {
  const {
    data,
    isError,
    error,
    isFetchingNextPage,
    hasNextPage,
    fetchNextPage,
  } = useInfiniteSubscription(
    'test-key',
    () => stream$,
    {
      getNextPageParam: (lastPage, allPages) => lastPage.nextCursor,
      // other options
    }
  );

  if (isError) {
    return (
      <div role="alert">
        {error?.message || 'Unknown error'}
      </div>
    );
  }
  return <>
    {data.pages.map((page) => (
      <div key={page.key}>{JSON.stringify(page)}</div>
    ))}
    {isFetchingNextPage && <>Loading...</>}
    {hasNextPage && (
      <button onClick={fetchNextPage}>Load more</button>
    )}
  </>;
}