📚 TL; DR

📖 Create

• 각 Stream의 구현체 ( Observable / Single ... )에 맞는 Emitter를 활용하여 데이터를 방출하는 operator
• 구독자가 stream을 구독 할 때마다 데이터를 방출

📖 Just

• 주어진 데이터를 바로 방출 하는 operator
• 객체 선언 즉시 데이터 방출을 시작
• 데이터가 방출되는 동안 Thread를 펜딩시키기 때문에, 사용에 유의 할 필요가 있음
• 한번 방출 된 데이터는, 내부적으로 저장되어 있기 때문에 observable을 재구독시 데이터 재발행을 하지 않고 저장된 데이터를 방출

📖 Defer

• Stream 객체를 구독하는 시점에 데이터 방출이 시작되도록 하는 operator
• Stream을 defer로 감싼 형태가 되기 때문에, Stream을 두개( defer Stream / defer 내부 Stream )를 만들어 주어야 함

📖 FromCallable

• Callable 인터페이스를 구현한 객체 내부의 함수를 동작시키고, call 함수의 결과값을 방출해주는 operator
• 구독자가 Stream을 구독 할 때 데이터 발행을 시작
• 네트워크 통신, DB 쿼리 작업 등 비동기 처리에 활용

📖 FromIterable

• Iterable 인터페이스를 구현하고 있는 객체를 인자로 받고, 객체 내부의 아이템들을 하나하나 꺼내어 데이터를 발행 해주는 operator

📖 Interval

• 일정한 시간 간격을 두고 0부터 시작하여 1씩 증가하는 숫자를 방출하는 operator