File tree Expand file tree Collapse file tree 4 files changed +37
-29
lines changed
Expand file tree Collapse file tree 4 files changed +37
-29
lines changed Original file line number Diff line number Diff line change @@ -15,10 +15,10 @@ path = "src/main.rs"
1515
1616[dependencies ]
1717# BAM/SAM parsing (pure Rust)
18- noodles-bam = " 0.68 "
19- noodles-sam = " 0.65 "
20- noodles-bgzf = { version = " 0.33 " , features = [" libdeflate" ] }
21- noodles-core = " 0.15 "
18+ noodles-bam = " 0.85 "
19+ noodles-sam = " 0.81 "
20+ noodles-bgzf = { version = " 0.45 " , features = [" libdeflate" ] }
21+ noodles-core = " 0.18 "
2222
2323# Parallelism
2424rayon = " 1.10"
Original file line number Diff line number Diff line change @@ -51,7 +51,7 @@ impl Default for RecordBatch {
5151/// BAM block reader that produces batches for parallel processing
5252pub struct BamBlockReader {
5353 /// Underlying BGZF reader (multi-threaded for parallel decompression)
54- reader : bgzf:: MultithreadedReader < File > ,
54+ reader : bgzf:: io :: MultithreadedReader < File > ,
5555 /// BAM header
5656 header : sam:: Header ,
5757 /// Pre-computed ref_id -> chrom_id mapping
@@ -84,7 +84,7 @@ impl BamBlockReader {
8484 // Use multi-threaded BGZF reader for parallel decompression
8585 let worker_count =
8686 NonZeroUsize :: new ( threads. max ( 1 ) ) . expect ( "thread count must be positive" ) ;
87- let mut reader = bgzf:: MultithreadedReader :: with_worker_count ( worker_count, file) ;
87+ let mut reader = bgzf:: io :: MultithreadedReader :: with_worker_count ( worker_count, file) ;
8888
8989 // Read BAM magic number
9090 let mut magic = [ 0u8 ; 4 ] ;
Original file line number Diff line number Diff line change @@ -118,7 +118,7 @@ pub struct AlignmentReader {
118118}
119119
120120enum ReaderInner {
121- Bam ( bam:: io:: Reader < bgzf:: MultithreadedReader < File > > ) ,
121+ Bam ( bam:: io:: Reader < bgzf:: io :: MultithreadedReader < File > > ) ,
122122 Sam ( sam:: io:: Reader < std:: io:: BufReader < File > > ) ,
123123}
124124
@@ -143,7 +143,7 @@ impl AlignmentReader {
143143 // Use multi-threaded BGZF reader for parallel decompression
144144 let worker_count =
145145 NonZeroUsize :: new ( threads. max ( 1 ) ) . expect ( "thread count must be positive" ) ;
146- let bgzf_reader = bgzf:: MultithreadedReader :: with_worker_count ( worker_count, file) ;
146+ let bgzf_reader = bgzf:: io :: MultithreadedReader :: with_worker_count ( worker_count, file) ;
147147 let mut bam_reader = bam:: io:: Reader :: from ( bgzf_reader) ;
148148 let header = bam_reader. read_header ( ) ?;
149149
@@ -186,7 +186,7 @@ impl AlignmentReader {
186186
187187 let worker_count =
188188 NonZeroUsize :: new ( threads. max ( 1 ) ) . expect ( "thread count must be positive" ) ;
189- let bgzf_reader = bgzf:: MultithreadedReader :: with_worker_count ( worker_count, file) ;
189+ let bgzf_reader = bgzf:: io :: MultithreadedReader :: with_worker_count ( worker_count, file) ;
190190 let mut bam_reader = bam:: io:: Reader :: from ( bgzf_reader) ;
191191 let header = bam_reader. read_header ( ) ?;
192192
You can’t perform that action at this time.
0 commit comments