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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
package KiokuDB::Stream::Objects;
BEGIN {
$KiokuDB::Stream::Objects::AUTHORITY = 'cpan:NUFFIN';
}
$KiokuDB::Stream::Objects::VERSION = '0.57';
use Moose;
# ABSTRACT: Data::Stream::Bulk with live object management.
use namespace::clean -except => 'meta';
has directory => (
isa => "KiokuDB",
is => "ro",
required => 1,
);
has entry_stream => (
does => "Data::Stream::Bulk",
is => "ro",
required => 1,
handles => [qw(is_done loaded)],
);
has linker => (
isa => "KiokuDB::Linker",
is => "ro",
lazy_build => 1,
);
sub _build_linker {
my $self = shift;
$self->directory->linker;
}
has live_objects => (
isa => "KiokuDB::LiveObjects",
is => "ro",
lazy_build => 1,
);
sub _build_live_objects {
my $self = shift;
$self->directory->live_objects;
}
has _scope => (
isa => "KiokuDB::LiveObjects::Scope",
writer => "_scope",
clearer => "_clear_scope",
);
has _no_scope => (
isa => "Bool",
is => "rw",
);
with qw(Data::Stream::Bulk) => { -version => 0.08, -excludes => 'loaded' };
sub next {
my $self = shift;
$self->_clear_scope;
my $entries = $self->entry_stream->next || return;;
if ( @$entries ) {
$self->_scope( $self->directory->new_scope )
unless $self->_no_scope;
for my $entry (@$entries) {
$self->live_objects->register_entry(
$entry->id => $entry,
in_storage => 1
) unless $self->live_objects->id_to_entry($entry->id);
}
return [ $self->linker->expand_objects(@$entries) ];
} else {
return [];
}
}
before all => sub { shift->_no_scope(1) };
__PACKAGE__->meta->make_immutable;
__PACKAGE__
__END__
=pod
=encoding UTF-8
=head1 NAME
KiokuDB::Stream::Objects - Data::Stream::Bulk with live object management.
=head1 VERSION
version 0.57
=head1 DESCRIPTION
This class is for object streams coming out of L<KiokuDB>.
C<new_scope> is called once for each block, and then cleared.
=head1 AUTHOR
Yuval Kogman <nothingmuch@woobling.org>
=head1 COPYRIGHT AND LICENSE
This software is copyright (c) 2014 by Yuval Kogman, Infinity Interactive.
This is free software; you can redistribute it and/or modify it under
the same terms as the Perl 5 programming language system itself.
=cut
|
