all

import rx.subject : SubjectObject;

auto sub = new SubjectObject!int;

bool result = false;
sub.all!"a % 2 == 0"().doSubscribe((bool res) { result = res; });

sub.put(0);
sub.completed();
assert(result);