nga-27

.ts

export function grpcUnary<T>(promise): Observable<T> {
    return from(promise).pipe(
        map((response: jspb.Message) => response.toObject()),
        catchError((error: Status) => {
            if (error.code === StatusCode.UNAUTHENTICATED) {
                jwtAuthError$.next();
            }

            return throwError(error);
        }),
    );
}