[Refactor] Re-use code in "merge_streams"

[ikatson]

We already have a create tokio_stream which has a function to merge 2 streams (which is almost identical to ours) - so remove the custom implementation.