async fn handle_compute_inner(
    client_id: u64,
    state: Arc<Mutex<Shared>>,
    socket: TcpStream,
    active_source_ids: &mut HashSet<SubscriptionId>,
    render_requests: UnboundedSender<SourceInstanceRequest>,
    storage_workers: usize
) -> Result<()>
Expand description

Inner portion to handle a compute client.