right, are you using something like connect, union, buffered stream?