participantmap.rb in openwferu-0.9.11

- old
+ new

@@ -135,11 +135,11 @@
             #ldebug { "lookup_participant() '#{participant_name}'" }
 
             @participants.each do |tuple|
                 return tuple[1] if tuple[0].match(participant_name)
             end
-            return nil
+            nil
         end
 
         #
         # Deletes the first participant matching the given name.
         #
@@ -151,11 +151,12 @@
                     pos = index
                     break
                 end
             end
             @participants.delete(pos) if pos > -1
-            return pos > -1
+            
+            pos > -1
         end
 
         #
         # Dispatches to the given participant.
         # The workitem will be fed to the consume() method of that participant.
@@ -185,9 +186,16 @@
 
             participant.consume(workitem)
 
             onotify :dispatch, :after_consume, workitem
         end
+
+        #
+        # The method onotify (from Osbservable) is made public so that
+        # ParticipantExpression instances may notify the pmap of applies
+        # and replies.
+        #
+        public :onotify
     end
 
 end
 