Language/Reactive
[리액티브 연산자 Operator 2] 에러, 유틸, 조건, 통지
5. 에러(ERROR) 처리 연산자 onErrorReturn 연산자 onErrorResumeNext 연산자 retry 연산자 6. UTILITY (유틸리티) 연산자 delay 연산자 delaySubscription 연산자 timeOut 연산자 timeInterval 연산자 materialize / dematerialize 7. 조건과 불린 연산자 all 연산자 amb 연산자 contains 연산자 defaultIfEmpty 연산자 sequenceEqual 연산자 8. 집계(MATHEMATICAL) 연산자 count 연산자 reduce 연산자 참고
[리액티브 연산자 Operator 1] 생성, 필터링, 변환, 결합,
리액티브 연산자 RxJava에서의 연산자는 메서드(함수)입니다. 연산자를 이용하여 데이터를 생성하고 통지하는 Flowable이나 Observable 등의 생산자를 생성할 수 있습니다. Flowable이나 Observable에서 통지한 데이터를 다양한 연산자를 사용하여 가공 처리하여 결괏값을 만들어 냅니다. 리액티브 연산자는 3-4백여개의 연산자가 있습니다. Flowable/Observable 생성 연산자 통지된 데이터를 필터링 해주는 연산자 통지된 데이터를 변환 해주는 연산자 여러 개의 Flowable/Observable을 결합하는 연산자 에러 처리 연산자 유틸리티 연산자 조건과 불린 연산자 통지된 데이터를 집계 해주는 연산자 각 연산자들을 마블 다이어그램으로 볼 수 있는 사이트 https://rxmar..
[리액티브 스트림즈(Reactive Streams)] Publisher, Subscriber, Subscription, Processor 4개 인터페이스 소개
리액티브 스트림즈(Reactive Streams)란? 리액티브 프로그래밍 라이브러리의 표준 사양이다. (github.com/reactive-streams/reactive-streams-jvm/ ) RxJava는 이 Reactive Streams의 인터페이스들을 구현한 구현체임. Reactive Streams는 Publisher, Subscriber, Subscription, Processor 라는 4개 인터페이스를 제공한다. 1. Publisher(생성자) : 데이터를 생성하고 통지(내보냄)한다. public interface Publisher { public void subscribe(Subscriber
리엑티브 프로그래밍(Reactive programming)
RxJava는 Reactive programming 패러다임을 Java에서 구현한 라이브러리 입니다. 리엑티브 프로그래밍(Reactive programming)이란? 위키피디아 reactive programming정의 1)a declarative programming paradigm concerned with 2)data streams and the propagation of change. 1) 선언적 프로그래밍 2) 변화의 전파와 데이터 흐름(비동기 프로그래밍) 변화의 전파와 데이터 흐름 관점 : 리엑티브 프로그래밍은 데이터가 변경 될 때 마다 이벤트를 발생시켜서 데이터를 계속적으로 전달하는 Push 방식을 따릅니다. Push 방식(비동기 방식) 데이터의 변화가 발생했을 때 변경이 발생한 곳에서 데이터..