lib/rbbt/util/concurrency/processes/socket.rb in rbbt-util-5.36.0 vs lib/rbbt/util/concurrency/processes/socket.rb in rbbt-util-5.37.0

@@ -26,9 +26,10 @@
       RbbtSemaphore.delete_semaphore(@read_sem)
     end
 
 
     def dump(obj, stream)
+      obj.concurrent_stream = nil if obj.respond_to?(:concurrent_stream)
       case obj
       when Annotated
         payload = @serializer.dump(obj)
         size_head = [payload.bytesize,"S"].pack 'La'
         str = size_head << payload