如何在颤动中测试更新PublishSubject或BehaviorSubject对象(RxDart)的异步函数

import 'package:rxdart/rxdart.dart';
import 'package:test/test.dart';

void main() {
  test('Test updating async function with PublishSubject or BehaviorSubject', () {
    // Test code goes here
  });
}

void main() {
  test('Test updating async function with PublishSubject or BehaviorSubject', () {
    final subject = PublishSubject<String>(); // or BehaviorSubject<String>('initial value')
    // Test code goes here
  });
}

void main() {
  test('Test updating async function with PublishSubject or BehaviorSubject', () {
    final subject = PublishSubject<String>(); // or BehaviorSubject<String>('initial value')
    
    subject.listen((data) {
      // Handle updated data
    });
    
    // Test code goes here
  });
}

void main() {
  test('Test updating async function with PublishSubject or BehaviorSubject', () {
    final subject = PublishSubject<String>(); // or BehaviorSubject<String>('initial value')
    
    subject.listen((data) {
      // Handle updated data
    });
    
    // Call the async function with subject
    myAsyncFunction(subject);
  });
}

Future<void> myAsyncFunction(Subject<String> subject) async {
  // Perform async operations
  // Update subject with new data
  subject.add('new data');
}

void main() {
  test('Test updating async function with PublishSubject or BehaviorSubject', () {
    final subject = PublishSubject<String>(); // or BehaviorSubject<String>('initial value')
    
    subject.listen((data) {
      expect(data, 'new data'); // Assert the updated data
    });
    
    myAsyncFunction(subject);
  });
}

Future<void> myAsyncFunction(Subject<String> subject) async {
  await Future.delayed(Duration(seconds: 1));
  subject.add('new data');
}