我想把一个可观察的东西变成一个行为主体.这样地:

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

我也try 过:

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$)
  }
}

那么,有没有一种更简单的方法可以在不使用类构造函数的情况下将可观察对象转换为行为主体呢?


这是我的真实情况:

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`
  }
}

推荐答案

不需要转换.

只需创建一个主题,并在其上附加可观察的: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

Note:obs.subscribe(sub)相当于:

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

Run it online

Typescript相关问答推荐

调用另一个函数的函数的Typescript类型,参数相同

在TypScript手册中可以视为接口类型是什么意思?

在这种情况下,如何获得类型安全函数的返回值?

在TypeScript中,除了映射类型之外还使用的`in`二进制运算符?

返回同时具有固定键和变量键的对象的函数的返回类型

角效用函数的类型推断

为什么不能使用$EVENT接收字符串数组?

以Angular 执行其他组件的函数

TypeScrip:强制使用动态密钥

为什么上下文类型在`fn|curred(Fn)`的联合中不起作用?

react 路由不响应参数

TypeScrip:使用Cypress测试包含插槽的Vue3组件

如何处理可能为空的变量...我知道这不是Null?

在Vite中将SVG导入为ReactComponent-不明确的间接导出:ReactComponent

Typescript 是否可以区分泛型参数 void?

如何根据Typescript 中带有泛型的对象嵌套键数组获取数组或对象的正确类型?

如何使用 AWS CDK 扩展默认 ALB 控制器策略?

如何确定剧作家中给定定位器的值?

redux-toolkit、createAsyncThunk 错误

如何使用布尔值构建对象 TYPE,但至少有一个必须为 true