# reactive programming
Reactor: BackPressure (배압)
소개 배압은 Reactor의 중요한 부분이다. 각 구독자는 구독 객체를 사용하여 처리한 이벤트를 요청한다. 발행자는 이벤트 요청의 수와 같거나 더 적은 이벤트를 발행해야한다. 이벤드 요청 수를 Lonb.MAX_VALUE로 설정하면 가지고 있는 이벤트를 전부 보낸다.
Reactor: Flow Control (흐름 조절)
Flow Control Flow Control은 생산자가 많은 이벤트를 발행하면서 구독자를 압박하지 않고 이벤트를 관리하는 것이다. 빠른 생산자는 많은 이벤트를 구독자에게 전달할 수 있다. 구독자는 이벤트를 받는 즉시 처리한다. 이러한 일련의 과정은 이벤트가 처리가능한
Reactor: 데이터와 스트림 처리
Reactor는 데이터를 조작하는 다양한 연산자를 제공한다. 이 연산자는 스트림을 받아서 다른 데이터로 구성된 스트림을 반환한다.본격적으로 연산자를 보기 전에 스트림 데이터를 생성해보자. 아래의 코드는 피보나치 수열을 생성하는 코드이다.결과결과결과결과결과결과위의 tak
Reactive Programming & Functinal Reactive Programming
what is reactive programming? Reactive programming의 개념적 의미 리액티브 프로그래밍은 행동을 변경하기 위해 결합된 이벤트의 지능형 라우팅 및 소비를하는 마이크로 아키텍처 스타일 또는 코드 레벨에서 이를 구현하는 것을 뜻합니다.
Kotlin에서 리액티브 프로그래밍 연습하기
리액티브 프로그래밍 선언적 프로그래밍 변화의 전파와 데이터 흐름 리액티브 프로그래밍은 보통 위 2가지 키워드로 설명되는데 개인적으로 이해한 내용을 정말 단순하게 풀어써보면 for문과 같은 반복문을 사용해서 명령형으로 데이터를 처리하던 것을 함수형 프로그래밍을 활용하
RxJS (Reactive Extenstions)
일단 RxJs가 무엇인지를 설명하기에 앞서 두 가지 용어를 먼저 이해할 필요가 있다.Reactive Programming (RP)Functional Reactive Programming (FRP)Reactive Extensions (Rx)Reactive programm
Combine Cheat Sheet
Apple에서 공개한 API인 Combine. 이제 Rx에서 Combine으로 많이 넘어간다고 한다. 무엇을 하는 것인지, 왜 좋은지, 바로 써먹기 위한 팁은 무엇이 있는지 알아본다.
flatMap & concatMap & flatMapSequential
flatMap은 방출되는 요소들의 순서를 보장하지 않는다 .flatMap은 Publisher의 up-stream(Publisher) 내부의 Element마다 각각의 inner publisher를 생성하여, 여러개의 하위 stream을 제공하고 이를 subscribe해서
프로그래밍 패러다임과 반응형 프로그래밍 그리고 Rx
설계에 관한 이야기를 먼저 쓰려고 했는데 먼저 설계의 원칙이라고 할 수 있는 프로그래밍 패러다임에 대한 설명이 선행이 되어야 할 것 같아, 현재 제가 쓰고 있는 개발 패러다임인 반응형 프로그래밍(Reactive Programming)에 대한 이야기를 해보고자 합니다.
Reactive Programming
Promise, Rx 등 비동기 처리를 하기 위한 방법은 많다. 이를 배워보기 이전에, 왜 그러한 개념이 나왔는지, 어떠한 방식으로 개선해왔는지를 코드를 고쳐보면서 이해해보는 것이 이 포스팅의 목표이다.
WebFlux (1) - 관련 키워드
[reactive-stack] [reactive programming] [reactive streams] [project reactor]
Rx
RxJava Reactive Extensions for the JVM 넷플릭스가 만든 Reactive Programming 개념의 자바 구현체 Reactive Programing Reactive Programming is programming with asynchr
Reactive programming의 간략한 정의
이 포스팅의 stream을 통한 예시는 The introduction to Reactive Programming you've been missing의 부분을 번역하여 작성했습니다. 정의 > Reactive programming is programming with a
[Android] RxJava란?
21.07.05 공부한 것을 정리하는 용도의 글이므로 100% 정확하지 않을 수 있습니다. 참고용으로만 봐주시고, 내용이 부족하다고 느끼신다면 다른 글도 보시는 것이 좋습니다.  + 틀린 부분, 수정해야 할 부분은 언제든지 피드백 주세요. 😊   &
scala + akka + websocket으로 agar.io를 만들어보자!
agar.io 클론 코딩githubScalaAkka Http, Akka Stream, Akka ActorWebsocketspray-json유저는 하나의 원으로 표현되고, 큰 원이 작은 원을 잡아먹음으로써 크기를 키워나가는 게임두 원의 중심 사이의 거리가 큰 원의 반지름
Thread per request VS EventLoop Model in Spring
Spring Web MVC는 Servlet API와 Servlet Container을 위해 만들어진 Spring 프레임워크 속 웹 프레임워크입니다. 하지만 Servlet Container(주로 Tomcat)에 의해 요청을 처리하기 때문에 요청당 Thread 하나가 매핑
[RxJava] Reactive Programming
https://ssionii.tistory.com/7 왜 비동기 작업을 해야할까? 사용자 경험 향상을 위해서. 사용자는 어플을 사용하는데에 있어서 중간에 어플이 멈추거나 느려지는 것을 원하지 않는다. 즉, 메인 스레드에서 너무 많은 작업을 하면 어플이 느려지거나
RxJava 입문하기 (Kotlin) - 기본2
지난 시간에 이어 RxJava의 연산자에 대해 알아보자. kotlin의 collection 함수들을 써봤다면 익숙한 함수들을 많이 만날 수 있다.
RxJava 입문하기 (Kotlin) - 기본1
Kotlin 언어로 RxJava를 사용하는 방법을 익혀보자.RxKotlin, RxAndroid 등 좀더 특화된 라이브러리도 있지만, 기본은 RxJava다.intelliJ 설치 (Comunity Edition이면 충분하다.)Gradle - Kotlin/JVM으로 프로젝트