Function dataflow::source::responsible_for

pub fn responsible_for(
    source_id: &GlobalId, 
    worker_id: usize, 
    worker_count: usize, 
    pid: &PartitionId
) -> bool

Returns true if the given source id/worker id is responsible for handling the given partition.