This repository has been archived by the owner on Jan 3, 2023. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 2
/
Copy pathLazyObjectPool.pm
90 lines (69 loc) · 1.55 KB
/
LazyObjectPool.pm
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
package LazyObjectPool;
use Moose;
use Moose::Util::TypeConstraints;
use Scalar::Util qw( blessed );
subtype 'LazyObjectStore' => as 'HashRef[Int|Object]';
coerce 'LazyObjectStore'
=> from 'ArrayRef[Int]'
=> via {
my %store = map {($_,$_)} @$_;
return \%store;
};
1;
has client => (
is => 'ro',
isa => 'Client',
required => 1,
);
has class => (
is => 'ro',
isa => 'Str',
required => 1,
);
has builder => (
is => 'ro',
isa => 'Str',
required => 1,
);
has store => (
is => 'ro',
isa => 'LazyObjectStore',
traits => ['Hash'],
required => 1,
default => sub {{}},
handles => {
_set_store => 'set',
_get_store => 'get',
keys => 'keys',
values => 'values',
has => 'exists',
},
coerce => 1,
);
sub _promote_key {
my $self = shift;
my $key = shift;
my $client = $self->client;
my $b_class = $self->class;
my $build = $self->builder;
my $obj = $b_class->$build( $client, $key );
$self->_set_store( $key, $obj );
return unless defined $obj;
return $obj;
}
sub get {
my $self = shift;
my $key = shift;
return unless $self->has( $key );
my $val = $self->_get_store( $key );
return $val if blessed $val;
return $self->_promote_key( $key );
}
sub members {
my $self = shift;
return map {
blessed $_ ? $_ : $self->_promote_key($_)
} $self->values;
}
__PACKAGE__->meta->make_immutable;
1;