dart - 对于 "pubsub.stream.listen(print, onDone: (){print(' 完成')})。 ", the "完成 :"never work

Question

从 Redis 获取消息时，onDone:(){print('done')} 从未起作用。

import 'package:dartis/dartis.dart' as redis show PubSub;

void main() async {
  final pubsub = await redis.PubSub.connect<String, 
String>('redis://localhost:6379');

// Subscribe to some channels and patterns
  pubsub
    ..subscribe(channel: 'dev.dart')
    ..psubscribe(pattern: 'message');

// Listen for server replies
  pubsub.stream.listen(print, onDone: (){
    print('done');
  });

我想要的只是在收到新消息时使用从 Redis 收到的消息运行自定义函数。紧急求救!

Answer 1

在这个片段中

pubsub.stream.listen(print, onDone: (){
  print('done');
});

print 的第一次出现称为撕裂，相当于:

pubsub.stream.listen((event) => print(event), onDone: (){
  print('done');
});

您应该看到打印的每个事件。

Stream 发出 MessageEvent - 请参阅 documentation . MessageEvent 具有属性 channel 和 message。

编写自己的函数来处理事件(例如)

void handleEvent(MessageEvent<String, String> event) => print(event.message);

然后像这样使用它

pubsub.stream.listen((event) => handleEvent(event), onDone: (){
  print('done');
});

或者，像这样重新引入撕纸

pubsub.stream.listen(handleEvent, onDone: (){
  print('done');
});