@@ 58-68 (lines=11) @@ | ||
55 | return $builder->build(); |
|
56 | } |
|
57 | ||
58 | private static function createTransport( |
|
59 | Locator $locator, |
|
60 | LoopInterface $loop, |
|
61 | array $options = [] |
|
62 | ): TransportClientInterface { |
|
63 | if (!isset($options[Options::TRANSPORT_OPTIONS])) { |
|
64 | throw new InvalidArgumentException('Missing Transport options'); |
|
65 | } |
|
66 | ||
67 | return TransportFactory::create($locator, $loop, $options[Options::TRANSPORT_OPTIONS]); |
|
68 | } |
|
69 | ||
70 | private static function createHydrator(LoopInterface $loop, CommandBusInterface $commandBus, array $options = []) |
|
71 | { |
|
@@ 70-77 (lines=8) @@ | ||
67 | return TransportFactory::create($locator, $loop, $options[Options::TRANSPORT_OPTIONS]); |
|
68 | } |
|
69 | ||
70 | private static function createHydrator(LoopInterface $loop, CommandBusInterface $commandBus, array $options = []) |
|
71 | { |
|
72 | if (!isset($options[Options::HYDRATOR_OPTIONS])) { |
|
73 | throw new InvalidArgumentException('Missing Hydrator options'); |
|
74 | } |
|
75 | ||
76 | return HydratorFactory::create($loop, $commandBus, $options[Options::HYDRATOR_OPTIONS]); |
|
77 | } |
|
78 | } |
|
79 |