1 files changed, 2 insertions, 2 deletions
diff --git a/lib/PublicInbox/DS.pm b/lib/PublicInbox/DS.pm
index 482710f7..7b87cd56 100644
--- a/lib/PublicInbox/DS.pm
+++ b/lib/PublicInbox/DS.pm
@@ -468,7 +468,7 @@ next_buf:
              }
          } else { #($ref eq 'CODE') {
              shift @$wbuf;
-            $bref->();
+            $bref->($self);
          }
      } # while @$wbuf
  
@@ -535,7 +535,7 @@ sub write {
          }
          return 0;
      } elsif ($ref eq 'CODE') {
-        $bref->();
+        $bref->($self);
          return 1;
      } else {
          my $to_write = bytes::length($$bref);