Made trade processing stream based; unified interface; added testing suite