rishi/scryer-prolog
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

match against Stream HttpRead(), InputFile(_) and NamedTcp(_) variants in read_term_from_user_input

Browse Source 
Signed-off-by: Thierry Marianne <thierry@marianne.io>
This commit is contained in:
Thierry Marianne
2025-09-14 17:00:39 +02:00
parent be18eda696
commit 1ece558a71
2 changed files with 19 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
src/machine/machine_state.rs
View File

@@ -755,30 +755,24 @@ impl MachineState {
); );
} }
#[cfg(feature = "http")] match stream {
if let Stream::HttpRead(_) = stream { #[cfg(feature = "http")]
return self.read_term( Stream::HttpRead(_) => {
stream, return self.read_term(
indices, stream,
MachineState::read_term_from_user_input_eof_handler, indices,
); MachineState::read_term_from_user_input_eof_handler,
} )
}
if let Stream::InputFile(_) = stream { Stream::InputFile(_) | Stream::NamedTcp(_) => {
return self.read_term( return self.read_term(
stream, stream,
indices, indices,
MachineState::read_term_from_user_input_eof_handler, MachineState::read_term_from_user_input_eof_handler,
); )
} }
_ => true,
if let Stream::NamedTcp(_) = stream { };
return self.read_term(
stream,
indices,
MachineState::read_term_from_user_input_eof_handler,
);
}
if let Stream::Byte(_) = stream { if let Stream::Byte(_) = stream {
return self.read_term( return self.read_term(

2
src/machine/system_calls.rs
View File

@@ -6756,7 +6756,7 @@ impl Machine {
Err(e) => { Err(e) => {
match self.user_input { match self.user_input {
Stream::Byte(_) | Stream::Readline(_) => self.user_input.reset(), Stream::Byte(_) | Stream::Readline(_) => self.user_input.reset(),
_ => true _ => true,
}; };
Err(e) Err(e)
} }