summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authordakkar <dakkar@thenautilus.net>2019-12-27 16:05:49 +0000
committerdakkar <dakkar@thenautilus.net>2019-12-27 16:06:13 +0000
commit95e5ec0fd4fe71477bb2c0fdc7307c7423a3e825 (patch)
tree14df228b61dd10318191e8b93668691b509e6907 /lib
parentmore address tests (diff)
downloadMaildirIndexer-95e5ec0fd4fe71477bb2c0fdc7307c7423a3e825.tar.gz
MaildirIndexer-95e5ec0fd4fe71477bb2c0fdc7307c7423a3e825.tar.bz2
MaildirIndexer-95e5ec0fd4fe71477bb2c0fdc7307c7423a3e825.zip
move scan-dir out of Store
Diffstat (limited to 'lib')
-rw-r--r--lib/MaildirIndexer/Store.pm68
1 files changed, 2 insertions, 6 deletions
diff --git a/lib/MaildirIndexer/Store.pm6 b/lib/MaildirIndexer/Store.pm6
index 5c95250..e1f2c5e 100644
--- a/lib/MaildirIndexer/Store.pm6
+++ b/lib/MaildirIndexer/Store.pm6
@@ -1,12 +1,11 @@
use v6.d;
unit class MaildirIndexer::Store;
use MaildirIndexer::Index;
-use MaildirIndexer::ScanDir;
use MaildirIndexer::Parser;
has Lock $!lock .= new;
has MaildirIndexer::Index @.indices is required;
-has Str $.maildir is required;
+has Channel $.file-channel is required;
has Int $.workers = 10;
method dump() {
@@ -16,12 +15,9 @@ method dump() {
}
method start() {
- my $file-supply = scan-dir($.maildir);
- my $file-channel = $file-supply.Channel;
-
for ^10 {
start react {
- whenever $file-channel -> $file {
+ whenever $.file-channel -> $file {
if $file.e && $file.f {
self.add-file($file);
}