rxdart BehaviorSubject事务

Question

在firebase中，我们可以像这样做事务

final dataRef = database.reference().child('path/to/data');

dataRef.runTransaction((MutableData transaction) async{
    transaction.value = (transaction.value ?? 0) + 1;
    return transaction;
});

我想知道我们在BehaviorSubject上也可以有同样的功能；就像这样

final subject = new BehaviorSubject<int>();

subject.add(1);
subject.add(2);
subject.add(3);
subject.runTransaction((int currentData) => currentData + 2);
// or 
subject.add(subject.value + 2);

subject.stream.listen(print); // prints 7
subject.stream.listen(print); // prints 7

Answer 1

我只是看了一下，看起来我们目前可以做到这一点。

1. 首先，“一旦Dart函数开始执行，它就会继续执行，直到退出。换句话说，Dart函数不能被其他Dart代码中断。“，ref (除了await关键字之外，它是一个很大的关键字，即使在技术上使用await已经是中断并在Future)
2. Secondly，中返回代码查看RxDart source code，add和setter都是同步的(没有Future，没有await)，所以下面的代码是简单的，并保证作为一个Dart工作

subject.add(subject.value + 2);