diff options
| author | Eric Wong <e@80x24.org> | 2021-04-05 10:27:50 +0000 |
|---|---|---|
| committer | Eric Wong <e@80x24.org> | 2021-04-05 19:10:14 +0000 |
| commit | ca7b99270e0574de573d29d6ba5b8a3bbdff82c5 (patch) | |
| tree | a811445aaea9a17cd75d86cb5660555ad25441da /t | |
| parent | cfd9e2ed62acdca0168fc3561a96f24568aff0fe (diff) | |
| download | public-inbox-ca7b99270e0574de573d29d6ba5b8a3bbdff82c5.tar.gz | |
We'll eventually want lei_input users like "lei import" and "lei tag" to support parallel reads.
Diffstat (limited to 't')
| -rw-r--r-- | t/lei-convert.t | 2 | ||||
| -rw-r--r-- | t/lei_to_mail.t | 8 |
2 files changed, 5 insertions, 5 deletions
diff --git a/t/lei-convert.t b/t/lei-convert.t index dc53b82c..0ea860c8 100644 --- a/t/lei-convert.t +++ b/t/lei-convert.t @@ -57,7 +57,7 @@ test_lei({ tmpdir => $tmpdir }, sub { lei_ok('convert', '-o', "$d/md", "mboxrd:$d/foo.mboxrd"); ok(-d "$d/md", 'Maildir created'); my @md; - PublicInbox::MdirReader::maildir_each_eml("$d/md", sub { + PublicInbox::MdirReader->new->maildir_each_eml("$d/md", sub { push @md, $_[2]; }); is(scalar(@md), scalar(@mboxrd), 'got expected emails in Maildir') or diff --git a/t/lei_to_mail.t b/t/lei_to_mail.t index 75314add..51357257 100644 --- a/t/lei_to_mail.t +++ b/t/lei_to_mail.t @@ -253,7 +253,7 @@ SKIP: { # FIFO support } { # Maildir support - my $each_file = PublicInbox::MdirReader->can('maildir_each_file'); + my $mdr = PublicInbox::MdirReader->new; my $md = "$tmpdir/maildir/"; my $wcb = $wcb_get->('maildir', $md); is(ref($wcb), 'CODE', 'got Maildir callback'); @@ -261,7 +261,7 @@ SKIP: { # FIFO support $wcb->(\(my $x = $buf), $b4dc0ffee); my @f; - $each_file->($md, sub { push @f, shift }); + $mdr->maildir_each_file($md, sub { push @f, shift }); open my $fh, $f[0] or BAIL_OUT $!; is(do { local $/; <$fh> }, $buf, 'wrote to Maildir'); @@ -270,7 +270,7 @@ SKIP: { # FIFO support $wcb->(\($x = $buf."\nx\n"), $deadcafe); my @x = (); - $each_file->($md, sub { push @x, shift }); + $mdr->maildir_each_file($md, sub { push @x, shift }); is(scalar(@x), 1, 'wrote one new file'); ok(!-f $f[0], 'old file clobbered'); open $fh, $x[0] or BAIL_OUT $!; @@ -281,7 +281,7 @@ SKIP: { # FIFO support $wcb->(\($x = $buf."\ny\n"), $deadcafe); $wcb->(\($x = $buf."\ny\n"), $b4dc0ffee); # skipped by dedupe @f = (); - $each_file->($md, sub { push @f, shift }); + $mdr->maildir_each_file($md, sub { push @f, shift }); is(scalar grep(/\A\Q$x[0]\E\z/, @f), 1, 'old file still there'); my @new = grep(!/\A\Q$x[0]\E\z/, @f); is(scalar @new, 1, '1 new file written (b4dc0ffee skipped)'); |