data streams - first commit