Как преобразовать Observable в BehaviorSubject? - PullRequest
Новая
       7

Как преобразовать Observable в BehaviorSubject?

0 голосов
/ 19 ноября 2018

Я пытаюсь преобразовать Observable в BehaviorSubject.Вот так: 

a$ = new Observable()
b$ = BehaviorSubject.create(new BehaviorSubject(123), a$)
// ?

Я также пробовал: 

a$ = new Observable()
b$ = new BehaviorSubject(a$, 123)
// ?

И: 

a$ = new Observable()
b$ = a$.asBehaviorSubject(123)
// ?

И: 

a$ = new Observable()
b$ = a$.pipe(
  toBehaviorSubject(123)
)
// ?

Но нетиз этих работ.Сейчас я должен реализовать это так: 

a$ = new Observable()
b$ = new BehaviorSubject(123)
a$.subscribe(b$)
// ?

Это было бы немного уродливо в классе: 

class Foo() {
  a$ = new Observable() // Actually, a$ is more complicated than this.
  b$ = new BehaviorSubject(123)

  constructor() {
    this.a$.subscribe(this.b$)
  }
}

Итак, есть ли более простой способ конвертировать Observable вa BehaviorSubject без использования конструктора класса?

Это мой реальный случай: 

export class Foo {
  autoCompleteItems$ = new BehaviorSubject<string[]>(null)
  autoCompleteSelected$ = new BehaviorSubject<number>(-1)
  autoCompleteSelectedChange$ = new Subject<'up'|'down'>()

  constructor() {
    this.autoCompleteItems$.pipe(
      switchMap((items) => {
        if (!items) return EMPTY
        return this.autoCompleteSelectedChange$.pipe(
          startWith('down'),
          scan<any, number>((acc, value) => {
            if (value === 'up') {
              if (acc <= 0) {
                return items.length - 1
              } else {
                return acc - 1
              }
            } else {
              if (acc >= items.length - 1) {
                return 0
              } else {
                return acc + 1
              }
            }
          }, -1)
        )
      })
    ).subscribe(this.autoCompleteSelected$)
  }

  doAutoComplete = () => {
    const item = this.autoCompleteItems$.value[this.autoCompleteSelected$.value]
    // do something with `item`
  }
}

Ответы [ 2 ]

0 голосов
/ 24 января 2019

Вот как я конвертирую свои Наблюдаемые объекты в Поведение: 

import { Observable } from 'rxjs/Observable';
import { BehaviorSubject } from 'rxjs/BehaviorSubject';

export function convertObservableToBehaviorSubject<T>(observable: Observable<T>, initValue: T): BehaviorSubject<T> {
    const subject = new BehaviorSubject(initValue);

    observable.subscribe(
        (x: T) => {
            subject.next(x);
        },
        (err: any) => {
            subject.error(err);
        },
        () => {
            subject.complete();
        },
    );

    return subject;
}
0 голосов
/ 20 ноября 2018

У меня тоже есть серьезные опасения по поводу варианта использования. Но тут приходит решение, не стесняйтесь голосовать, пока вы тоже оставляете отзыв. Поскольку BehaviourSubject и любые другие Subject являются Observables, 

import { BehaviorSubject, from } from 'rxjs'; 
import { map, mergeMap } from 'rxjs/operators';


const source$ = from([1,2,3,4,5,6,7,8,9]);
const bs = new BehaviorSubject('start')
    .pipe(
        mergeMap(() => source$)
    );

bs.subscribe(console.log);
...