all

1 import rx.subject : SubjectObject;
2 
3 auto sub = new SubjectObject!int;
4 
5 bool result = false;
6 sub.all!"a % 2 == 0"().doSubscribe((bool res) { result = res; });
7 
8 sub.put(0);
9 sub.completed();
10 assert(result);