(concurrency 갯수 설정해서 consumer 수 정할 수 도 있는 등)
그나저나
rx에서 Observable stream을 여러개를 operator로 엮을 수 있는게
가장 신기하고 또 재밋어 보였습니다.
http://rxmarbles.com 여기서 operator를 살펴보세요ㅋㅋ
본론으로 다시 돌아와, 제가 worker queue를 만든다면
signal용 subject(이하 $) (signal을 count에 맞춰서 보내면 worker concurrency 흉내낼 수 있기때문)
buffer용 observable (혹은 걍 데이터용 $)
그리고 zip 용도로 쓰일 observable
그래서스샷처럼만들어봤는데
worker의 subscribe 더 하면 worker가 추가되는 형식이고
$.next로 queue에 task넣을수잇고..
암튼 이런데요
이것보다 더 적절한 approach 있을까요??
stream을 여러개묶어서 하는 operator가 참잼나긴하네요
근데 좀 길을돌아가는느낌이라 async 모듈도 섞어써야겟음요.
잡담 | 1486명이 읽었어요. 3.145.183.137
