Странная проблема Rxjs с BehaviorSubject

Проблема в том, что вы звоните this.http.get<IDataFromServer[]>('/api/rest') внутри getAll, но никто никогда не подписывается на него.

Первый журнал, который вы упомянули, должен быть null, потому что вы инициализируете свой BehaviorSubject нулем.

Что вам нужно, так это просто вернуть http.get из getAll, чтобы любой, кто вызывает этот метод и подписывается на него, запускал HTTP-вызов. Кроме того, tap позаботится о том, чтобы ваши данные в BehaviorSubject были обновлены.

 getAll(): Observable<IDataFromServer[]> {
    return
        this.http.get<IDataFromServer[]>('/api/rest')
        .pipe(
            tap(data => this.dataFromServer.next(data))
        );
 }

Хотя вы не включили часть, где вы вызываете функцию add, я почти уверен, что вы не подписываетесь на ее результат.

У вас может быть строка кода, которая говорит что-то вроде

myService.add(myItem);

Теперь это вернет Observable. Однако обратите внимание, что если никто не подпишется на этот Observable, подключенные каналы не будут активированы.

Следовательно, у вас есть два решения.

Первое: не используйте tap, а подписывайтесь. Я почти уверен, что это то, что вы хотите. Это выглядит так:

add(item: IDataFromServer): void {
    this.http.post<IDataFromServer>('/api/manage', item)
        .subscribe(data => {
            let internal = this.dataFromServer.getValue();
            if (!internal) {
                internal = new Array<IDataFromServer>();
            }
            internal.push(material);
            this.dataFromServer.next(internal);
        }
    );
}

Второе: Подпишитесь на результат add. Что-то вроде этого:

myService.add(myItem).subscribe();

Проблема возникает из-за распространенного неправильного понимания Observables. Может этот пост поможет.

Вместе с отличными ответами на вопрос, почему ваше решение не работает, я добавлю свое мнение о том, что не так с вашим подходом.

Из того, что я вижу, вы пытаетесь предоставить единственную наблюдаемую из вашей службы, которая будет использоваться при каждом вызове REST, позволяя представлениям отделять и повторно использовать логику визуализации данных от входа в систему обновления данных (а именно, им просто нужно будет отображать данные один раз и каждый раз, когда они обновляют данные, будет вызываться одна и та же логика).

Проблема в том, что httpClient Observables ленивы, фактически отправляют запросы, только если кто-то подписывается.

Я сделал то же самое, и обычно я скрываю http-вызовы в своем сервисе и подписываюсь внутри. Заимствуя ваши классы, это будет выглядеть так:

export class MyService {
    private dataFromServer = new BehaviorSubject<IDataFromServer[]>(null);

    constructor(private http: HttpClient) { }

    getAll(): Observable<IDataFromServer[]> {
        this.http.get<IDataFromServer[]>('/api/rest')
                 .subscribe(data => this.dataFromServer.next(data));
        return this.dataFromServer.asObservable();
    }

    add(item: IDataFromServer): Observable<any> {
        return this.http.post<IDataFromServer>('/api/manage', item)
                        .subscribe(data => this.dataFromServer.next(data));
    }
}

Я также предполагаю, что ваша конечная точка следует принципам REST, поэтому путь /api/manage возвращает в качестве ответа полный список, обновленный новыми добавленными данными, точно так же, как вызов /api/rest/ возвращается после вызова POST.