We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8827b71 commit 088a91aCopy full SHA for 088a91a
src/query/service/src/servers/http/v1/query/sized_spsc.rs
@@ -57,6 +57,9 @@ struct SizedChannelBuffer {
57
max_rows: usize,
58
page_rows: usize,
59
pages: VecDeque<Page>,
60
+
61
+ /// The current_page gets moved outside the lock to spilling and then moved back in, or cleared on close.
62
+ /// There's a lot of unwrap here to make sure there's no unintended behavior that's not by design.
63
current_page: Option<PageBuilder>,
64
is_recv_stopped: bool,
65
is_send_stopped: bool,
0 commit comments