istream/FifoBufferSink: obey IstreamBucketList::ShouldFallback()

CM4all · Aug 17, 2023 · 3d31a6c · 3d31a6c
1 parent c55dac9
commit 3d31a6c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/istream/FifoBufferSink.cxx b/src/istream/FifoBufferSink.cxx
@@ -60,6 +60,9 @@ FifoBufferSink::OnIstreamReady() noexcept
 	if (!handler.OnFifoBufferSinkData())
 		return IstreamReadyResult::CLOSED;
 
+	if (list.ShouldFallback())
+		result = IstreamReadyResult::FALLBACK;
+
 	return result;
 }