代码之家 › 专栏 › 技术社区 › Adrian Brand

Rxjs share操作符未给出预期结果

rxjs6 rxjs

Adrian Brand · 技术社区 · 7 年前

我正在尝试让rxjs操作符共享像 https://www.learnrxjs.io/operators/multicasting/share.html ,但我没有得到预期的结果。我希望“Running map函数”只记录一次。我错过什么了吗?

const { of } = rxjs;
const { map, share } = rxjs.operators;

const obs$ = of('data');

const mapped$ = obs$.pipe(map(d => {
  console.log('Running map function');
  return `mapped ${d}`;
}));

const shared$ = mapped$.pipe(share());

shared$.subscribe(d => { console.log(d); });

shared$.subscribe(d => { console.log(d); });

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.3.3/rxjs.umd.min.js"></script>

1 回复 | 直到 7 年前

dsych 7 年前

如前所述,你的潜艇是同步的。要获得预期的行为,可以使用调度程序。从你可以阅读的节杖开始 this article

const { of, Observable, asyncScheduler } = rxjs;
const { map, share, observeOn } = rxjs.operators;

const obs$ = of('data').pipe(observeOn(asyncScheduler));

const mapped$ = obs$.pipe(map(d => {
  console.log('Running map function');
  return `mapped ${d}`;
}));

const shared$ = mapped$.pipe(share());

shared$.subscribe(d => { console.log(d); });

shared$.subscribe(d => { console.log(d); });

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.3.3/rxjs.umd.min.js"></script>

推荐文章

Ole · 在使用新的Angular Resource API时取消搜索术语?

1 年前

koque · 为什么我的RxJs主题没有按预期工作?

1 年前

Raphaël VO · 不使用Observable的初始值

1 年前

xarielah · 从app.config.ts调用时,BehaviorSubject不会更新

1 年前

Lenni · 返回信号并在Angular中订阅它

1 年前

dman · 在Angular单元测试中似乎无法模拟行为主体

1 年前

Nevyan Dimitrov Neykov · 效果内部的角度信号()

1 年前

Ð¤ÐµÐ´Ñ Ð Ð°Ð²ÑÐµÐµÐ² · 如何在react-js中使用Date()在后台增加变量?

2 年前

Ryley38 · 如何跳过流的第一个值,除非它是RxJS的复制粘贴?

2 年前

techwestcoastsfosea · Angular 18-RxJS:Subscribe已弃用[重复]

2 年前