Обработчик подписки первого и второго наблюдателя - PullRequest
Новая
       31

Обработчик подписки первого и второго наблюдателя

0 голосов
/ 05 марта 2019

У меня есть такой код: 

const i = 0;
const subject = webSocket(WEBSOCKET_API_URL);

subject.subscribe(
  msg => {
    if(i===0) {
      firstHandler();
    }
    if(i===1) {
      secondHandler();
    }
    else {
      globalHanlder();
    }
    if(i <= 2) { 
      i++;
    }
  }
);

subject.next({
  event: "testSubscribe",
});

Я хочу подписаться на канал WebSocket, отправить сообщение и обработать 2 первых ответа иначе, чем другие.

Я сделал этокак вы можете видеть выше.Мне не нравится решение.И мне интересно, есть ли какой-нибудь более красивый способ сделать это для обработки первого и второго вызова функции с использованием rxjs.

У вас есть какие-нибудь идеи?

Ответы [ 2 ]

0 голосов
/ 05 марта 2019

Лично я бы сделал это почти так же, как вы.Возможно, я бы предпочел, чтобы переменная i была определена внутри цепочки.Возможно, если вам не нужны значения, выдаваемые subject, вы можете заменить их на индексы.

subject.pipe(
  map((value, index) => index),
).subscribe(index => {
  if (index === 0) {
    firstHandler();
  } else if (index === 1) {
    secondHandler();
  } else {
    globalHanlder();
  }
});
0 голосов
/ 05 марта 2019

Я думаю, что ваше решение в порядке.Не необходимый очиститель с оператором Observable, но следующий будет делать то же самое 

const 1st=subject.pipe(take(2),last(),tap(()=>firstHandler()))
const 2nd=subject.pipe(first(),tap(()=>secondHandler()))
const other=subject.pipe(skip(2),tap(()=>globalHandler()))
merge(1st,2nd,other).subscribe()
...