lib/rbbt/util/concurrency/processes/socket.rb in rbbt-util-5.34.11 vs lib/rbbt/util/concurrency/processes/socket.rb in rbbt-util-5.34.12

@@ -27,10 +27,14 @@
     end
 
 
     def dump(obj, stream)
       case obj
+      when Annotated
+        payload = @serializer.dump(obj)
+        size_head = [payload.bytesize,"S"].pack 'La'
+        str = size_head << payload
       when String
         payload = obj
         size_head = [payload.bytesize,"C"].pack 'La'
         str = size_head << payload
       else
@@ -88,10 +92,10 @@
   
     
     def push(obj)
       RbbtSemaphore.synchronize(@write_sem) do
         multiple = MultipleResult === obj
-        obj = Annotated.purge(obj)
+        #obj = Annotated.purge(obj)
         obj.extend MultipleResult if multiple
         self.dump(obj, @swrite)
       end
     end