SharedFlow란?

[gaeun5744]

SharedFlow는 모든 수집자(collectors)에게 방출된 값을 방송 방식으로 공유하는 hot Flow 입니다. 즉, 모든 수집자가 방출된 모든 값을 받을 수 있습니다.

SharedFlow가 뜨겁다고 하는 이유는 수집자의 존재 여부와 관계없이 활성 인스턴스가 독립적으로 존재하기 때문입니다.

특징

• never complete
  • SharedFlow에서 Flow.collect를 호출하면 정상적으로 완료되지 않으며, Flow.lauchIn 함수로 시작되는 코루틴도 마찬가지 입니다. Shared Flow의 활성 수집자를 구독자(subscriber)라고 부릅니다.
• 구독 취소 가능
  • SharedFlow의 구독자는 취소할 수 있습니다. 이는 일반적으로 코루틴이 실행 중인 스코프가 취소될 때 발생합니다. Shared Flow의 구독자는 항상 취소 가능하며, 각 방출 전에 취소 여부를 확인합니다.
  • 대부분 terminal 연산자, 예를 들어 Flow.toList와 같은 연산자는 Shared Flow에서 완료되지 않습니다. 그러나 Flow.take 또는 Flow.takeWhile과 같은 흐름 중단(flow-truncating) 연산자를 사용하면 Shared Flow를 완료 가능한 형태로 변환할 수 있습니다.
• 가변 Shared Flow 생성
  • MutableSharedFlow 생성자 함수를 사용하여 가변 Shared Flow를 생성할 수 있습니다. 이 상태는 값을 방출하거나 기타 작업을 수행하여 업데이트 할 수 있습니다.

[junjange]

SharedFlow란 무엇인가요?

SharedFlow는 Kotlin Flow의 한 종류로, 핫 스트림(hot stream)을 구현하기 위해 사용됩니다. SharedFlow는 다수의 구독자들에게 공유된 이벤트 스트림을 제공하며, 반복(replay) 설정을 통해 과거의 이벤트를 새로운 구독자에게 전달할 수 있는 유연한 기능을 제공합니다. 이는 특히 실시간 이벤트 처리, 사용자 인터랙션, UI 이벤트 스트림 등 여러 구독자가 동일한 이벤트를 받아야 하는 상황에서 유용하게 사용됩니다.

SharedFlow의 주요 특징

1. 핫 스트림 (Hot Stream):

   • SharedFlow는 스트림이 생성될 때 이미 데이터 생성이 시작되며, 구독자가 없어도 데이터는 계속 방출됩니다.
   • 모든 구독자가 동일한 데이터 흐름을 공유합니다.

2. 반복(replay) 설정:

   • SharedFlow는 replay 파라미터를 통해 새로운 구독자에게 과거의 이벤트를 몇 개까지 재방출할지 설정할 수 있습니다.
   • 예를 들어, replay = 1로 설정하면 마지막 이벤트를 새로운 구독자에게 즉시 전달합니다.

3. 버퍼 관리:

   • extraBufferCapacity와 onBufferOverflow 설정을 통해 버퍼링 전략을 정의할 수 있습니다.
   • 이는 생산자와 소비자의 속도 차이를 관리하는 데 도움을 줍니다.

4. 공유성 (Sharing):

   • SharedFlow는 여러 구독자가 동일한 스트림을 공유하므로, 리소스 사용이 효율적입니다.
   • 이벤트 기반 로직에서 동일한 이벤트를 여러 곳에서 처리할 때 유용합니다.

SharedFlow의 장단점

장점:

• 유연한 이벤트 처리: 여러 구독자가 동일한 이벤트를 받을 수 있어, 다양한 컴포넌트 간의 이벤트 공유가 용이합니다.
• 버퍼 설정의 유연성: replay, extraBufferCapacity, onBufferOverflow 설정을 통해 다양한 요구 사항에 맞게 버퍼링 전략을 조정할 수 있습니다.
• Hot Stream: 구독자와 무관하게 데이터가 계속 방출되므로, 실시간 데이터 스트림에 적합합니다.

단점:

• 복잡성: replay와 버퍼 설정 등 다양한 옵션을 이해하고 적절히 설정해야 합니다.
• 상태 관리 한계: 단일 상태 관리에는 StateFlow가 더 적합하며, SharedFlow는 주로 이벤트 스트림에 사용됩니다.