Moving continual searching into a celluloid actor class, support for listening to multiple streams.