Início / coding / Perguntas / 79421514
Accepted
ph3rin
Asked: 2025-02-08 00:11:28 +0800 CST

Crie um fluxo que emitirá um único valor constante para cada assinatura uma vez

  • 772

Quero criar um fluxo que possa emitir um único valor para cada assinante, não importa quando ele se inscreveu.

O ideal seria que o código a seguir imprimisse dois 42antes de done, mas nenhuma das abordagens fornecidas funciona.

void main() async {
  final stream = createStream(42);
  stream.listen(printValue);
  await Future.delayed(Duration(seconds: 1));
  stream.listen(printValue);

  // Wait for everything to finish.
  await Future.delayed(Duration(seconds: 1));
  print('done');
}

Stream<int> createStream(int val) {
  // Error: Stream has already been listened to.
  // return Stream.value(val);

  // Only gets one output
  return Stream.value(val).asBroadcastStream();
}

void printValue(int val) {
  print(val);
}

Saída desejada:

42
42
done

Mas Stream.value()gera um erro Stream has already been listened to.. Enquanto .asBroadcastStream()dá o resultado errado.

Observação: respostas usando o RxDart serão bem-vindas.

flutter

1 respostas

  1. Best Answer

    Você pode obter a saída desejada usando um fluxo de múltiplas assinaturas:

    void main() async {
  final stream = createStream(42);
  stream.listen(printValue);
  await Future.delayed(Duration(seconds: 1));
  stream.listen(printValue);

  // Wait for everything to finish.
  await Future.delayed(Duration(seconds: 1));
  print('done');
}

/// Returns a multi-subscription stream.
Stream<int> createStream(int val) => Stream.multi((streamController) {
      streamController.add(val);
    });

void printValue(int val) {
  print(val);
}

    A saída do console está listada abaixo:

    $ dart main.dart 
42
42
done

    Observação: outra maneira fácil de criar um fluxo de múltiplas assinaturas é usando o construtor de fábrica Stream.fromIterable:

    /// Returns a multi-subscription stream that yields only `val`.
Stream<int> createStream(int val) => Stream.fromIterable([val]);
    • 1

relate perguntas