subscribe object propertiesas rxjs operators

[Judimax]

Greetings to all
everyone familar with the Observer properties (next,complete,error)
wouldn't it be nice to have them as rxjs operators, it would make our code look much cleaner

[voliva]

Do you have any example? It's a bit hard to picture without one

[Judimax]

[voliva]

Personally I rather have it in subscribe - As it's what executes the observable and looks for updates.

I like to see the operators that you'd put inside .pipe as functions that somehow transform the observable or use the observable without directly subscribing on it. If you need to make a side effect on one of the events we have tap:

.pipe(
  tap({
    next: () => {}
  })
)

But having to add in extra operators to just subscribe feels unnecessary and a bit harder to read to me.

[Judimax]

// @ts-nocheck
import {of} from 'rxjs';
import {next,error,complete,subscribe} from 'rxjs/operators';


of({})
.pipe(
    timeout(2500),
    concatMap(() => of(1)),
    exhaust(),
    next(()=>{}),
    error(()=>{}),
    complete(()=>{}),
)
.subscribe()

ajax("www.google.com")
.pipe(
    concatMap(() => of(1)),
    exhaust(),    
    next(()=>{}),
    error(()=>{}),
    complete(()=>{}),
)
.subscribe()


defer(()=>{return from(myPromise)})
.pipe(
    concatMap(() => of(1)),
    mergeMap(() => of(1)),
    error(()=>{}),
)
.subscribe()


http.post(
    endpoint,
    {large JSON body},
    {many headers and params}
)
.pipe(
    takeUntil(()=>{return true}),
    complete(()=>{}),
)
.subscribe()

would be neater than how we would regularly treat the Observer object properties