Fix Zing/Domain false start issue (#190)

awncorp · Jul 5, 2020 · cfebfab · cfebfab
1 parent e5f2490
commit cfebfab
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 15 deletions.
diff --git a/lib/Zing/Domain.pm b/lib/Zing/Domain.pm
@@ -33,12 +33,6 @@ fun new_channel($self) {
   Zing::Channel->new(name => $self->name)
 }
 
-has 'threshold' => (
-  is => 'ro',
-  isa => 'Str',
-  def => 1_000,
-);
-
 # BUILDERS
 
 fun BUILD($self) {
@@ -75,18 +69,15 @@ sub _copy {
 # METHODS
 
 method apply() {
-  if ($self->channel->renew) {
-    undef $self->{data} if $self->channel->size;
-  }
+  undef $self->{data} if $self->channel->renew;
 
   while (my $data = $self->recv) {
     my $op = $data->{op};
     my $key = $data->{key};
     my $val = $data->{val};
 
     if ($data->{snapshot} && !$self->{data}) {
-      $self->{data} = _copy $data->{snapshot};
-      next;
+      $self->{data} = _copy($data->{snapshot});
     }
 
     local $@;
@@ -123,13 +114,11 @@ method apply() {
 method change(Str $op, Str $key, Any @val) {
   my %fields = (
     key => $key,
-    snapshot => $self->data,
+    snapshot => _copy($self->data),
     time => time,
     val => [@val],
   );
 
-  $self->channel->drop if $self->channel->size >= $self->threshold;
-
   if ($op eq 'decr') {
     $self->send({ %fields, op => 'decr' });
   }

diff --git a/t/Zing_Domain.t b/t/Zing_Domain.t
@@ -66,7 +66,6 @@ Zing::Types
 
 name: ro, req, Str
 channel: ro, opt, Channel
-threshold: ro, opt, Str
 
 =cut