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

@@ -202,10 +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.lockfile = stream.lockfile if stream.respond_to? :lockfile
     out
   end
 
   class << self
     alias tee_stream tee_stream_thread