Mutate Value Of Subscribe Object Without Convert It To Observable

[mahdi-farnia]

hi, i'm new to RxJS and reactive programming. I asked my question in stackoverflow but i didn't get any response yet!

i want to use these two solutions together with RxJS but I don't know how to do it.

// Sample code, this does not work properly :(, because next is not defined on Observable
const dummy = new Subject<number>().pipe(
  map((num) => num + 1)
);

dummy.subscribe((number) => {
  // expects 4 but get 3
})

dummy.next(3)

short explanation is:

I want to emit data everywhere even outside of observable construction like Subscribe, and operate on each data emit using pipe method like Observable.

I can implement a simple emitter class that simulate this behavior but I want a RxJS way.

BTW this is stackoverflow question link

Thanks 🙏

Actually this question has been answered you can see the answer on stackoverflow website

[jakovljevic-mladen]

Would this work?

const dummy = new Subject<number>();

const result = dummy.pipe(map((num) => num + 1));

result.subscribe((number) => {
  // expects 4 but get 3
});

dummy.next(3)