fix(streaming): clear data stream on subject completion
fix(streaming): clear data stream on subject completion

grafana/grafana,grafana/grafana,grafana/grafana,grafana/grafana,grafana/grafana,grafana/grafana,grafana/grafana