lib/rbbt/persist.rb in rbbt-util-5.13.35 vs lib/rbbt/persist.rb in rbbt-util-5.13.36

@@ -202,9 +202,10 @@
       end
     end
     ConcurrentStream.setup(out, :threads => saver_thread, :filename => path)
     out.callback = callback
     out.abort_callback = abort_callback
+    out.lockfile = stream.lockfile
     out
   end
 
   class << self
     alias tee_stream tee_stream_thread