First implementation of streaming search

AMENDME