Как заставить pipe работать асинхронно без постоянного указывания |async в шаблонах в angular 2?

Question

[Abc Edc]

@Pipe({
  name: 'someRand',
  pure: false
})
export class RandomPipe implements PipeTransform {
  constructor(private  cdRef:ChangeDetectorRef) {
  }

  transform(value:string):any {
    return new AsyncPipe(this.cdRef).transform(new Observable<string>(observer=>{
      observer.next('rand1');
      setTimeout(()=>{
        observer.next('rand@2');
      })
    }));
  }
}

Как заставить пайп вывести строку внутри таймаута, потому что в такой реализации работает только синхронный вывод - 'rand1'

Answer 1

[Алексей Зуев]

Думаю можно вот таким образом

@Pipe({
  name: 'someRand',
  pure: false
})
export class RandomPipe implements PipeTransform {
  constructor(private  cdRef:ChangeDetectorRef) {}

  pipe: AsyncPipe;
  obs: Observable<string>;

  transform(value:string):any {
    if (!this.pipe) {
      this.pipe = new AsyncPipe(this.cdRef);
      this.obs = new Observable<string>(observer=>{
        observer.next('rand1');
        setTimeout(()=>{
          observer.next('rand@2');
        }, 600)
      });
    }
  
    return this.pipe.transform(this.obs);
  }
}

600 добавил просто ради асинхронности)

Comments

[Abc Edc]

Стоп стоп,а почему? :D потому что obs в паблике? или что помогло заработать? потому что я теоритически понимал что оно должно работать , там в пайпе
AsyncPipe.prototype._updateLatestValue = function (async, value) {
if (async === this._obj) {
this._latestValue = value;
this._ref.markForCheck();
}
};
Такая строчка есть потому что

[Алексей Зуев]

ГЛЕБ ГЛЕБОВ: здесь две вещи, первая мы сохраняем asyncpipe, который инкапсулирует всю подписку и change detection, второе мы сохраняем сам объект observable, потому что в AsyncPipe есть строка if (obj !== this._obj) {. Т.е. если не сохраним, то потеряем всю цепочку выполнения

[Алексей Зуев]

В твоем изначальном варианте ты получаешь бесконечный цикл выполнения

[Алексей Зуев]

Изначальный вариант был такое https://plnkr.co/edit/Ot3t1IlGa9QbDEaCDK2Y?p=preview. Но я потом подумал, а зачем я буду трогать private поле если asyncpipe сам может всё распаковать

[Abc Edc]

Алексей Зуев Спасибо , я понял!