Simplifying nested subscriptions in RxJS

Question

I have two observables

clients$ is a stream of client connections

data$ is a stream that delivers data endlessly

Whenever a client connects, I subscribe to data$ and send it to the client.

I read that nesting subscriptions is a no-go in RxJS, so this approach is probably wrong.

const clients$ = createClientStream()
const data$ = Observable.interval(1000).share()

clients$.subscribe(c => {

  const s = data$.subscribe(d => c.send(d))

  c.on('disconnect', () => s.unsubscribe())

})

What is the idiomatic RxJS approach to this?

user3743222 · Accepted Answer · 2016-05-24 00:29:58Z

2

You could use flatMap.

const clients$ = createClientStream()
const data$ = Observable.interval(1000).share()

clients$
  .flatMap(c => {
     const disconnect$ = Rx.Observable.create (observer => {
       c.on('disconnect', () => {observer.onNext({}); observer.onCompleted();})
     })
     return data$.takeUntil(disconnect$)
  }, (c,d) => c.send(d))

edited May 24, 2016 at 0:29

answered May 24, 2016 at 0:20

user3743222

18.7k5 gold badges74 silver badges75 bronze badges

Sign up to request clarification or add additional context in comments.

2 Comments

K.. Over a year ago

how does this integrate the disconnect?

user3743222 Over a year ago

I added the disconnect part.

Collectives™ on Stack Overflow

Simplifying nested subscriptions in RxJS

1 Answer 1

2 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

2 Comments

Your Answer

Sign up or log in

Post as a guest

Related