Parametrize PayloadOrderer on Payload params

JuliaData · Jun 16, 2023 · ed5cf0c · ed5cf0c
1 parent 6931b45
commit ed5cf0c
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/payload.jl b/src/payload.jl
@@ -20,10 +20,10 @@ last_row(payload::ParsedPayload) = (payload.row_num + length(payload) - 1)
 #
 
 # Like a Channel, but when you take! a Payload from it, it will be the next one in order
-mutable struct PayloadOrderer
-    queue::Channel{ParsedPayload}
+mutable struct PayloadOrderer{B<:AbstractResultBuffer, C<:AbstractParsingContext}
+    queue::Channel{ParsedPayload{B,C}}
     expected_row::Int
-    waititng_room::Vector{ParsedPayload}
+    waititng_room::Vector{ParsedPayload{B,C}}
 end
 PayloadOrderer(queue::Channel) = PayloadOrderer(queue, 1, sizehint!(ParsedPayload[], Threads.nthreads()))
 PayloadOrderer() = PayloadOrderer(Channel{ParsedPayload}(Inf), 1, sizehint!(ParsedPayload[], Threads.nthreads()))