processor
-
리액티브 스트림즈(Reactive Streams)Spring Reactive Web Application/Reactive Programming 2023. 7. 21. 05:00
리액티브 스트림즈(Reactive Streams) 데이터 스트림을 Non-Blocking이면서 비동기적인 방식으로 처리하기 위한 리액티브 라이브러리의 표준 사양입니다. 리액티브 스트림즈를 구현한 구현체로 RxJava, Reactor, Akka Streams, Java 9 Flow API 등이 있습니다. 리액티브 스트림즈 구성요소 Publisher: 데이터를 생성하고 통지(발행, 게시, 방출)하는 역할을 합니다. Subscriber: 구독한 Publisher로부터 통지(발행, 게시, 방출)된 데이터를 전달받아서 처리하는 역할을 합니다. Subscription: Publisher에 요청할 데이터의 개수를 지정하고, 데이터의 구독을 취소하는 역할을 합니다. Processor: Publisher와 Subscri..
-
SubjectBackEnd/RxJava 2023. 7. 14. 07:00
Processor vs Subject Processor Reactive Streams에서 정의한 Publisher 인터페이스와 Subscriber 인터페이스를 둘 다 상속한 확장 인터페이스입니다. 즉, Publisher(생산자)의 기능과 Subscriber(소비자)의 기능을 모두 가지고 있습니다. Hot Publisher(뜨거운 생산자)입니다. Note) Hot Publisher vs Cold Publisher Hot Publisher: 소비자는 구독한 시점의 타임라인부터 통지된 데이터를 받을 수 있습니다. Cold Publisher: 소비자는 구독할 때마다 타임라인의 처음부터 모든 데이터를 받을 수 있습니다. Subject Reactive Streams의 Processor와 동일한 기능을 하나 배압 기..
-
Reactive StreamsBackEnd/RxJava 2023. 7. 1. 09:00
Reactive Streams Github 리액티브 프로그래밍 라이브러리의 표준 사양입니다. RxJava는 Reactive Streams의 인터페이스들을 구현한 구현체입니다. Reactive Streams는 Publisher, Subscriber, Subscription, Processor 4개의 인터페이스를 제공합니다. Publisher 데이터를 생성하고 통지합니다. public interface Publisher { public void subscribe(Subscriber