File Coverage

blib/lib/RxPerl/BehaviorSubject.pm

Criterion	Covered	Total	%
statement	29	29	100.0
branch	3	6	50.0
condition			n/a
subroutine	9	9	100.0
pod	0	2	0.0
total	41	46	89.1

package RxPerl::BehaviorSubject;

use strict;
use warnings;

use base 'RxPerl::Subject';

use Carp 'croak';
use Scalar::Util 'weaken';

our $VERSION = "v6.27.1";

sub _on_subscribe {
    my ($self, $subscriber) = @_;

    $subscriber->{next}->($self->{_last_value}) if defined $subscriber->{next};
}

sub new {
    my ($class, $initial_value) = @_;

    @_ == 2 or croak 'missing initial value for behavior subject';

    my $self = $class->SUPER::new();

    $self->{_last_value} = $initial_value;

    weaken(my $w_self = $self);
    my $next_orig = $self->{next};
    $self->{next} = sub {
        $w_self->{_last_value} = $_[0] unless $w_self->{_closed};
        $next_orig->(@_);
    };

    bless $self, $class;
}

sub get_value {
    my ($self) = shift;

    return $self->{_last_value};
}

1;