useExampleStream.ts

import { useCallback, useState } from 'react';
import { useStream } from '../dist';
import { ExampleSubscriberClient } from './services/example_subscriber.client';
import transport from './transport';

function streamFn(abortController: AbortController) {
    const call = new ExampleSubscriberClient(transport).subscribe(
        {
            id: 1,
            name: 'Lorem',
        },
        {
            abort: abortController.signal,
        }
    );

    return call;
}

export default function useExampleStream() {
    const [data, setData] = useState([]);
    const onSuccess = useCallback((result) => {
        setData(result);
    }, []);

    useStream('example', streamFn, {
        onSuccess,
    });

    return {
        data,
        isLoading: !data,
    };
}