Buffer added
pipe data through es.wait instead of push/loop