js stream aggr (not finished)