View GitHub Repository PEIP

Schedule Inspection
Subscribe

Code Duplication    Length = 6-6 lines in 2 locations

src/ABS/Channel/SubscribableChannel.php 1 location

@@ 76-81 (lines=6) @@
73 
     */
74 
    public function setMessageDispatcher(\PEIP\INF\Dispatcher\Dispatcher $dispatcher, $transferListeners = true)
75 
    {
76 
        if (isset($this->dispatcher) && $transferListeners) {
77 
            foreach ($this->dispatcher->getListeners() as $listener) {
78 
                $dispatcher->connect($listener);
79 
                $this->dispatcher->disconnect($listener);
80 
            }
81 
        }
82 
        $this->dispatcher = $dispatcher;
83 
    }
84 

                                

                                                                        

                

                                                            

                    
src/Pipe/Pipe.php 1 location

                

                

                    

                                                
                                                    

                                
                                
                                    @@ 159-164 (lines=6) @@
                                
                            


                                                            

                                    156
                                    
                                    
     */

                                

                                                            

                                    157
                                    
                                    
    public function setMessageDispatcher(\PEIP\INF\Dispatcher\Dispatcher $dispatcher, $transferListeners = true)

                                

                                                            

                                    158
                                    
                                    
    {

                                

                                                            

                                    159
                                    
                                    
        if (isset($this->dispatcher) && $transferListeners) {

                                

                                                            

                                    160
                                    
                                    
            foreach ($this->dispatcher->getListeners() as $listener) {

                                

                                                            

                                    161
                                    
                                    
                $dispatcher->connect($listener);

                                

                                                            

                                    162
                                    
                                    
                $this->dispatcher->disconnect($listener);

                                

                                                            

                                    163
                                    
                                    
            }

                                

                                                            

                                    164
                                    
                                    
        }

                                

                                                            

                                    165
                                    
                                    
        $this->dispatcher = $dispatcher;

                                

                                                            

                                    166
                                    
                                    
        $this->doFireEvent(self::EVENT_SET_MESSAGE_DISPATCHER, [self::HEADER_DISPATCHER => $dispatcher]);

                                

                                                            

                                    167
                                    
                                    
    }