RxDart는 Flutter 애플리케이션에서 리액티브 프로그래밍을 구현하는 데 사용되는 라이브러리입니다. 이 라이브러리는 다양한 연산자를 제공하여 데이터 스트림을 다루고 변형할 수 있습니다. 이번 글에서는 몇 가지 RxDart의 연산자 사용 방법에 대해서 알아보겠습니다.

1. map 연산자

map 연산자는 데이터 스트림에 대해 변형을 수행합니다. 이 연산자는 Stream 클래스의 메소드로 사용할 수 있으며, 각각의 이벤트를 다른 값으로 매핑합니다. 예를 들어, 다음은 정수 데이터 스트림을 문자열로 변환하는 예제입니다.

import 'package:rxdart/rxdart.dart';

void main() {
  final numbers = Observable.fromIterable([1, 2, 3, 4, 5]);
  
  final stringNumbers = numbers.map((number) => number.toString());
  
  stringNumbers.listen(print);
}

위 코드에서 numbers 스트림에 대해 map 연산자를 사용하여 각 숫자를 문자열로 변환하고 있습니다. 변환된 문자열 스트림인 stringNumbers를 구독하면 변환된 값들이 출력됩니다.

2. filter 연산자

filter 연산자는 데이터 스트림에서 조건에 맞는 이벤트만을 걸러냅니다. 이 연산자는 Stream 클래스의 메소드로 사용할 수 있으며, 각각의 이벤트를 걸러내기 위해 조건 함수를 적용합니다. 다음은 숫자 스트림에서 홀수만을 걸러내는 예제입니다.

import 'package:rxdart/rxdart.dart';

void main() {
  final numbers = Observable.fromIterable([1, 2, 3, 4, 5]);
  
  final oddNumbers = numbers.filter((number) => number % 2 != 0);
  
  oddNumbers.listen(print);
}

위 코드에서 numbers 스트림에 대해 filter 연산자를 사용하여 홀수를 걸러내고 있습니다. 홀수로 걸러진 스트림인 oddNumbers를 구독하면 홀수만이 출력됩니다.

3. debounce 연산자

debounce 연산자는 데이터 스트림에서 일정 시간 동안 이벤트가 없을 때에만 이벤트를 발생시킵니다. 이 연산자는 Stream 클래스의 메소드로 사용할 수 있으며, 일정 시간 동안 이벤트가 없을 때를 설정하기 위해 Duration 객체를 인자로 전달합니다. 다음은 사용자 입력 데이터 스트림에서 일정 시간 동안 이벤트가 없을 때에만 이벤트를 발생시키는 예제입니다.

import 'package:rxdart/rxdart.dart';

void main() {
  final userInput = Observable.fromIterable(['A', 'B', 'C', 'D', 'E']);
  
  final debouncedInput = userInput.debounceTime(Duration(milliseconds: 500));
  
  debouncedInput.listen(print);
}

위 코드에서 userInput 스트림에 대해 debounce 연산자를 사용하여 500밀리초 동안 이벤트가 없을 때에만 이벤트를 발생시키고 있습니다. 따라서 사용자 입력 후 500밀리초 동안 다른 입력이 없을 때에만 입력 값이 출력됩니다.

RxDart는 이 외에도 많은 연산자를 제공하며, 이를 조합하여 다양한 데이터 스트림 조작을 할 수 있습니다. 자세한 내용은 RxDart 공식 문서를 참조하시기 바랍니다.