1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
use strict;
use warnings;
use Test::More;
use Try::Tiny;
use Message::Passing::Input::Null;
use Message::Passing::Output::Test;
plan skip_all => "No IO::Compress"
unless try { require Message::Passing::Filter::Decoder::Bzip2; require Message::Passing::Filter::Encoder::Gzip };
use_ok 'Message::Passing::Filter::Decoder::Bzip2';
use_ok 'Message::Passing::Filter::Encoder::Bzip2';
use_ok 'Message::Passing::Filter::Encoder::Gzip';
use_ok 'Message::Passing::Filter::Decoder::Gzip';
my $gzt = Message::Passing::Output::Test->new;
my $gz = Message::Passing::Input::Null->new(
output_to => Message::Passing::Filter::Encoder::Gzip->new(
output_to => Message::Passing::Filter::Decoder::Gzip->new(
output_to => $gzt,
),
),
);
$gz->output_to->consume('test');
is $gzt->message_count, 1;
is_deeply [$gzt->messages], ['test'];
my $bzt = Message::Passing::Output::Test->new;
my $bz = Message::Passing::Input::Null->new(
output_to => Message::Passing::Filter::Encoder::Gzip->new(
output_to => Message::Passing::Filter::Decoder::Gzip->new(
output_to => $bzt,
),
),
);
$bz->output_to->consume('test');
is $bzt->message_count, 1;
is_deeply [$bzt->messages], ['test'];
done_testing;
|
