
에러처리 연산자 3가지 onErrorRetrun 연산자 에러가 발생했을때 에러를 의미하는 데이터로 대체 할 수 있음 onErrorReturn( ) 을 호출하면 onError 이벤트는 발생하지 않음onErrorResumeNext 연산자 에러가 발생했을때 에러를 의미하는 Observable로 대체 할 수 있음Observable 로 대체 할 수 있으므로 데이터 교체와 더불어 에러 처리를 위한 추가 작업을 할 수 있음 retry 연산자 데이터 통지 중 에러가 발생했을때, 데이터 통지를 재시도 함 onError 이벤트가 발생하면 subscribe( )를 다시 호출하여 재구독함에러가 발생한 시점에 통지 실패한 데이터만 다시 통지되는 것이 아니라 처음부터 다시 통지됨출처 : 인프런 (Kevin의 알기쉬운 RxJav..
함수형 인터페이스와 람다의 개념 파악함수형 인터페이스 ▶ 단 하나의 추상 메서드만 가지고 있는 인터페이스이다. (예외: 디폴트 메서드는 포함 할 수 있음) ▶ 함수형 인터페이스의 메서드를 람다 표현식으로 작성해서 다른 메서드의 파라미터로 전달 할 수 있음 ▶ 즉, 람다 표현식 전체를 해당 함수형 인터페이스를 구현한 클래스의 인스턴스로 취급함 ▶ Java 8에서는 기존의 추상 메서드가 하나만 있는 인터페이스도 함수형 인터페이스로 간주람다 표현식 (String a, String b) -> a.equals(b)----람다 파라미터 -- 화살표 -- 람다 몸체--- ▶ 람다 표현식은 함수형 인터페이스를 구현한 클래스 즉, 익명 클래스의 메서드를 단순화 한 표..
Single ▶데이터를 1건만 통지하거나 에러를 통지 ▶데이터 통지 자체가 완료를 의미하기 때문에 완료 통지는 하지 않음 ▶데이터를 1건만 통지하므로 데이터 개수를 요청할 필요가 없음 ▶onNext( ) , oncomplete( ) 가 없으며 이 둘을 합한 onSuccess( ) 를 제공함 ▶ Single의 대표적인 소비자는 SingleObserver임 ▶클라이언트의 요청에 대응하는 서버의 응답이 Single을 사용하기 좋은 대표적인 예 Maybe ▶데이터를 1건만 통지하거나 1건도 통지하지 않고 완료 또는 에러를 통지함 ▶데이터 통지 자체가 완료를 의미하기 때문에 완료 통지는 하지 않음 ▶단, 데이터를 1건도 통지하지 않고 처리가 종료될 경우에는 완료 통지를 함 ▶Maybe 의 대표적..
Flowable 과 Observable의 비교 Flowable Reactive Streams 인터페이스를 구현함Subscriber에서 데이터를 처리함 ReactiveStreams에서 기본스펙으로 정해놓은 인터페이스 데이터 개수를 제어하는 배압기능이 있음 Subscription으로 전달 받는 데이터 개수를 제어할 수 있음Subscription로 구독을 해지 Observable Reactive Streams 인터페이스를 구현하지 않음Observer에서 데이터를 처리함RxJava 에서 독자적으로 제공하는 클래스데이터 개수를 제어하는 배압기능이 없음배압 기능이 없기때문에 데이터 개수를 제어할 수 없음Disposable로 구독을 해지 배압 (Back Pressure) 이란 ? Flowable에서 데이터를 통지하..
리액티브 스트림즈(Reactive Streams)- 리액티브 프로그래밍 라이브러리의 표준사양- 리액티브 프로그래밍에 대한 인터페이스만 제공함- RxJava는 이 Reactive Streams의 인터페이스들을 구현한 구현체임- Reactive Streams는 Publisher, Subscriber,Subscription, Processor 라는 4개의 인터페이스를 제공함 ● Publisher : 데이터를 생성하고 통지 ● Subscriber : 통지된 데이터를 전달받아서 처리 ● Subscription : 전달 받을 데이터의 개수를 요청하고 구독을 해지 ● Processor : Publisher 와 Subscriber의 기능이 모두 있음 Cold Publisher & Hot Publish..