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

Я пытаюсь преобразовать 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 в 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`
  }
}

person awmleer    schedule 19.11.2018    source источник
comment
Что для этого нужно? Обычно вы можете использовать только merge. Я думаю, что использование subscribe - это наиболее эффективный способ.   -  person martin    schedule 19.11.2018
comment
По какой причине вы хотите преобразовать Observable в BehaviourSubject? Это потому, что вы хотите иметь доступ к последнему значению? В этом случае вы можете посмотреть shareReply или последовательность publishReplay и refCount   -  person Picci    schedule 19.11.2018
comment
@Picci Да. Я хочу иметь доступ к последнему значению. Спасибо за совет! Я собираюсь взглянуть на эти API.   -  person awmleer    schedule 19.11.2018
comment
@Picci На самом деле я хочу написать что-нибудь вроде b$.value или b$.getValue().   -  person awmleer    schedule 19.11.2018
comment
Что касается тем, value и getValue являются запахами кода, и их лучше избегать.   -  person cartant    schedule 19.11.2018
comment
@cartant Спасибо за совет. Я думаю, мне нужно реорганизовать свой код ...   -  person awmleer    schedule 22.11.2018


Ответы (3)


Конвертировать его не нужно.

Просто создайте тему и прикрепите к ней наблюдаемое с помощью: obs.subscribe(sub)

пример:

var obs = new rxjs.Observable((s) => {setTimeout(()=>{s.next([1])} , 500)}) //observable
var sub = new rxjs.BehaviorSubject([0]) //create subject
obs.subscribe(sub) //<----- HERE ----- attach observable to subject
setTimeout(() => {sub.next([2, 3])}, 1500) //subject updated
sub.subscribe(a => console.log(a)) //subscribe to subject

Примечание. obs.subscribe(sub) эквивалентно:

obs.subscribe({
  next: v => sub.next(v),
  error: v => sub.error(v),
  complete: () => sub.complete()
})

Запустить онлайн

person yaya    schedule 02.10.2019
comment
Я думаю, что это самый идиоматический способ преобразования наблюдаемых в предметы в rxjx f, и его следует принять как правильный ответ @awmleer - person mikey; 18.11.2019
comment
Субъект может считаться наблюдателем, поэтому его можно использовать непосредственно в качестве аргумента для подписки. obs.subscribe (sub). Вместо того, чтобы вручную подключаться к sub.next, error к sub.error и т. Д. - person Noémi Salaün; 03.04.2020

Вот как я конвертирую свои Observables в BehaviorSubjects:

import { Observable, BehaviorSubject } from 'rxjs';

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

    observable.subscribe(subject);

    return subject;
}
person tmuecksch    schedule 24.01.2019
comment
Отписывается ли подписка после return? Как мы уверены, что утечки памяти нет? - person Juozas Rastenis; 28.03.2020
comment
@JuozasRastenis Нет, этот код не отменяет подписку - очевидно. Но вы можете реализовать эту функцию самостоятельно. Этот фрагмент предназначен только для того, чтобы стать полезной отправной точкой для вашего собственного решения. - person tmuecksch; 30.03.2020

Меня тоже беспокоит вариант использования. Но вот решение, не стесняйтесь голосовать против, если вы тоже оставляете отзыв. Поскольку 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);
person Luillyfe    schedule 20.11.2018
comment
Спасибо за ответ! Но bs по-прежнему наблюдаемый, а bs.value не определен. - person awmleer; 22.11.2018