diff --git a/src/protocols/protocol_filter_out_70015.cpp b/src/protocols/protocol_filter_out_70015.cpp index 06348d85..6ac5d4bd 100644 --- a/src/protocols/protocol_filter_out_70015.cpp +++ b/src/protocols/protocol_filter_out_70015.cpp @@ -222,7 +222,7 @@ bool protocol_filter_out_70015::handle_receive_get_filters(const code& ec, span(events::ancestry_msecs, start); send_filter(error::success, ancestry); - return false; + return true; } void protocol_filter_out_70015::send_filter(const code& ec, @@ -233,11 +233,7 @@ void protocol_filter_out_70015::send_filter(const code& ec, return; if (ancestry->empty()) - { - // Complete, resubscribe to get_client_filters. - SUBSCRIBE_CHANNEL(get_client_filters, handle_receive_get_filters, _1, _2); return; - } const auto& query = archive(); const auto start = logger::now();