@@ -38,48 +38,48 @@ public function __construct(Connection $connection, SerializerInterface $seriali
3838 */
3939 public function get (): iterable
4040 {
41- return ( $ this ->receiver ?? $ this -> getReceiver () )->get ();
41+ return $ this ->getReceiver ()->get ();
4242 }
4343
4444 /**
4545 * {@inheritdoc}
4646 */
4747 public function ack (Envelope $ envelope ): void
4848 {
49- ( $ this ->receiver ?? $ this -> getReceiver () )->ack ($ envelope );
49+ $ this ->getReceiver ()->ack ($ envelope );
5050 }
5151
5252 /**
5353 * {@inheritdoc}
5454 */
5555 public function reject (Envelope $ envelope ): void
5656 {
57- ( $ this ->receiver ?? $ this -> getReceiver () )->reject ($ envelope );
57+ $ this ->getReceiver ()->reject ($ envelope );
5858 }
5959
6060 /**
6161 * {@inheritdoc}
6262 */
6363 public function getMessageCount (): int
6464 {
65- return ( $ this ->receiver ?? $ this -> getReceiver () )->getMessageCount ();
65+ return $ this ->getReceiver ()->getMessageCount ();
6666 }
6767
6868 /**
6969 * {@inheritdoc}
7070 */
7171 public function send (Envelope $ envelope ): Envelope
7272 {
73- return ( $ this ->sender ?? $ this -> getSender () )->send ($ envelope );
73+ return $ this ->getSender ()->send ($ envelope );
7474 }
7575
7676 private function getReceiver (): BeanstalkdReceiver
7777 {
78- return $ this ->receiver = new BeanstalkdReceiver ($ this ->connection , $ this ->serializer );
78+ return $ this ->receiver ?? = new BeanstalkdReceiver ($ this ->connection , $ this ->serializer );
7979 }
8080
8181 private function getSender (): BeanstalkdSender
8282 {
83- return $ this ->sender = new BeanstalkdSender ($ this ->connection , $ this ->serializer );
83+ return $ this ->sender ?? = new BeanstalkdSender ($ this ->connection , $ this ->serializer );
8484 }
8585}
0 commit comments