streaming based on mltframework