diff --git a/streaming/stream_transfer_task.cc b/streaming/stream_transfer_task.cc
index fec39ec162..b66e164f38 100644
--- a/streaming/stream_transfer_task.cc
+++ b/streaming/stream_transfer_task.cc
@@ -90,7 +90,7 @@ struct send_info {
     }
 };
 
-future<> do_send_mutations(auto si, auto fm, bool fragmented) {
+future<> do_send_mutations(lw_shared_ptr<send_info> si, frozen_mutation fm, bool fragmented) {
     return get_local_stream_manager().mutation_send_limiter().wait().then([si, fragmented, fm = std::move(fm)] () mutable {
         sslog.debug("[Stream #{}] SEND STREAM_MUTATION to {}, cf_id={}", si->plan_id, si->id, si->cf_id);
         auto fm_size = fm.representation().size();
@@ -112,7 +112,7 @@ future<> do_send_mutations(auto si, auto fm, bool fragmented) {
     });
 }
 
-future<> send_mutations(auto si) {
+future<> send_mutations(lw_shared_ptr<send_info> si) {
     return repeat([si] () {
         return si->reader().then([si] (auto smopt) {
             if (smopt && si->db.column_family_exists(si->cf_id)) {