diff options
-rw-r--r-- | lib/MaildirIndexer/Parser.rakumod | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/MaildirIndexer/Parser.rakumod b/lib/MaildirIndexer/Parser.rakumod index d30ca86..c92fa22 100644 --- a/lib/MaildirIndexer/Parser.rakumod +++ b/lib/MaildirIndexer/Parser.rakumod @@ -86,7 +86,7 @@ multi parse-email(IO::Path:D $p, :$headers-only! --> MaildirIndexer::Email) is e return $result; } -multi parse-email(IO::Socket::Async:D $s --> MaildirIndexer::Email) is export { +multi parse-email(IO::Socket::Async:D $s, Int $timeout = 1 --> MaildirIndexer::Email) is export { my MaildirIndexer::Email $result; MaildirIndexer::LogTimelineSchema::Parse::Email::Socket.log: -> { my $string; @@ -99,6 +99,7 @@ multi parse-email(IO::Socket::Async:D $s --> MaildirIndexer::Email) is export { $result = parse-email($string) and done; QUIT { done }; } + whenever Promise.in($timeout) { done } } } return $result; |