Code Duplication    Length = 9-9 lines in 4 locations

src/Channel/ChannelComposite.php 2 locations

@@ 311-319 (lines=9) @@
308
     * @override
309
     * @inheritDoc
310
     */
311
    public function send($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0)
312
    {
313
        if ($success !== null || $failure !== null || $cancel !== null)
314
        {
315
            return $this->sendRequest($name, $message, $flags, $success, $failure, $cancel, $timeout);
316
        }
317
318
        return $this->sendAsync($name, $message, $flags);
319
    }
320
321
    /**
322
     * @override
@@ 325-333 (lines=9) @@
322
     * @override
323
     * @inheritDoc
324
     */
325
    public function push($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0)
326
    {
327
        if ($success !== null || $failure !== null || $cancel !== null)
328
        {
329
            return $this->pushRequest($name, $message, $flags, $success, $failure, $cancel, $timeout);
330
        }
331
332
        return $this->pushAsync($name, $message, $flags);
333
    }
334
335
    /**
336
     * @override

src/Channel/Channel.php 2 locations

@@ 326-334 (lines=9) @@
323
     * @override
324
     * @inheritDoc
325
     */
326
    public function send($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0)
327
    {
328
        if ($success !== null || $failure !== null || $cancel !== null)
329
        {
330
            return $this->sendRequest($name, $message, $flags, $success, $failure, $cancel, $timeout);
331
        }
332
333
        return $this->sendAsync($name, $message, $flags);
334
    }
335
336
    /**
337
     * @override
@@ 340-348 (lines=9) @@
337
     * @override
338
     * @inheritDoc
339
     */
340
    public function push($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0)
341
    {
342
        if ($success !== null || $failure !== null || $cancel !== null)
343
        {
344
            return $this->pushRequest($name, $message, $flags, $success, $failure, $cancel, $timeout);
345
        }
346
347
        return $this->pushAsync($name, $message, $flags);
348
    }
349
350
    /**
351
     * @override