Effect CommunityEC
Effect Community4y ago
4 replies
Patrick Roza

```ts

Observable("test")
  .map((_) => _ + _)
  .mergeMap((_) => Observable([_]))
  .tap((_) => Observable(console.log(_))) // bs obviously
  .subscribe()

compiled to:
import * as tsplus_module_1 from "ts-plus-test/rxjs/bindings";
tsplus_module_1.toArray_(tsplus_module_1.tap_(tsplus_module_1.mergeMap_(tsplus_module_1.map_(tsplus_module_1.of("test"), (_) => _ + _), (_) => tsplus_module_1.of([_])), (_) => tsplus_module_1.of(console.log(_)))).subscribe();

https://github.com/patroza/ts-plus-test/blob/rxjs/_src/rxjs/usage.ts
on rxjs branch: yarn && yarn build && yarn start
Was this page helpful?