o [Fix] do not block while pushing existing messages of a source when
adding a new subscription to that source