big_dada.r

big_dada <- function(X){
cat("Processing:", X, "\n")
cat("Derep F:", X, "\n")
derepF <- derepFastq(filtpathF[[X]])
cat("Inferring F:", X, "\n")
ddF <- dada(derepF, err=errF, multithread=TRUE)
cat("Derep R:", X, "\n")
derepR <- derepFastq(filtpathR[[X]])
cat("Inferring R:", X, "\n")
ddR <- dada(derepR, err=errR, multithread=TRUE)
cat("Merging:", X, "\n")
merger <- mergePairs(ddF, derepF, ddR, derepR)
return(list(merger = merger, dadaFs = ddF, dadaRs = ddR))
}
library(pbmcapply)
names(filtpathF) <- sample.names
names(filtpathR) <- sample.names
mergers_l <- pbmclapply(sample.names, big_dada, mc.cores = 16)

# names(mergers_l) <- sample.names
# dadaFs <- purrr::map(mergers_l, "dadaFs")
# dadaRs <- purrr::map(mergers_l, "dadaRs")
# mergers <- purrr::map(mergers_l, "merger")