Created Concurrent::Observable mixin and added to several classes.