streaming node implementation finished