ожидание данных буфера fini sh с rx js наблюдаемым - PullRequest
0 голосов
/ 18 марта 2020

Я получаю данные кэша Redis и хочу вернуть данные после завершения sh, но здесь данные возвращают фрагменты, так что это приводит к неполным данным

const checkDetailCache = (key: string): Observable<any> => {

    const getCache = bindNodeCallback(storageClient.get.bind(storageClient)) as (key: string) => Observable<any>;

    return (getCache(key).pipe(
        first(),
        switchMap(
            (value) => iif(
                () => value === null,
                of(null),
                of(value).pipe(
                    map((result: Buffer) => {
                        // return data after finish 
                        return result.toString();
                    }),
                ),
            ),
        ),
    ));
}

есть ли способ завершить sh весь буфер Затем данные обрабатываются только с операторами rx js или я допустил ошибку в своем коде

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...