stream pipeline