문서 보기역링크PDF로 내보내기맨 위로 이 문서는 읽기 전용입니다. 원본을 볼 수는 있지만 바꿀 수는 없습니다. 문제가 있다고 생각하면 관리자에게 문의하세요. # RxPy ```python import rx stream = rx.subject.Subject() c = stream.pipe( # ops.take_while(lambda i: i < 60) ops.filter(lambda i: i < 60) ) c.subscribe(on_next=lambda i: print("i is {}".format(i))) stream.on_next(0) stream.on_next(50) stream.on_next(51) stream.on_next(49) stream.on_next(100) stream.on_next(-50) ``` ```python from rx.scheduler import ThreadPoolScheduler import multiprocessing optimal_thread_count = multiprocessing.cpu_count() pool_scheduler = ThreadPoolScheduler(optimal_thread_count + 1) composed = source.pipe( ops.filter(lambda d: not d['IsPlusAD'] and not d['IsPowerClickAD']), # ops.take(1), ops.map_indexed(lambda x, i: (x, i)), ops.delay(0.1, pool_scheduler) ) composed.subscribe(on_next=on_next_data) ``` open/rxpy.txt 마지막으로 수정됨: 2020/06/02 09:25저자 127.0.0.1