У меня есть служба, которая загружает файл JSON и использует эту службу в пользовательском канале:
import { Pipe, PipeTransform } from '@angular/core';
import { Observable } from 'rxjs/Rx';
import { LanguageLoadService } from '../../services/language-load/language-load.service';
@Pipe({name: 'langAsset'})
export class LangAsset implements PipeTransform {
constructor(private languageService: LanguageLoadService) {
}
transform(textKey: string): Observable<any> {
return new Observable(observer => {
this.languageService.loadLanguage("en-US").subscribe((langData) => {
observer.next(langData[textKey] ? langData[textKey] : 'Error');
})
});
}
}
И по шаблону:
<p>{{'test' | langAsset | async }}</p>
Но кажется, что преобразование запускается до того, как служба завершит загрузку JSON, так как результатом будет [object Object] на странице, и console.log распечатывает его нормально, когда он регистрируется внутри подписки loadLanguage. Как я могу заставить это повториться, возвращая наблюдаемое вместо строки в функции преобразования? Я знаю, что должен использовать AsyncPipe, но не знаю, как это сделать.
