7
7
use Http \Client \HttpClient ;
8
8
use Http \Discovery \MessageFactoryDiscovery ;
9
9
use Http \Discovery \StreamFactoryDiscovery ;
10
- use Http \Message \MessageFactory ;
10
+ use Http \Message \ResponseFactory ;
11
11
use Http \Message \StreamFactory ;
12
12
use Http \Promise \Promise ;
13
13
use Psr \Http \Message \RequestInterface ;
@@ -39,11 +39,11 @@ class Client implements HttpClient, HttpAsyncClient
39
39
private $ options ;
40
40
41
41
/**
42
- * PSR-7 message factory
42
+ * PSR-7 response factory
43
43
*
44
- * @var MessageFactory
44
+ * @var ResponseFactory
45
45
*/
46
- private $ messageFactory ;
46
+ private $ responseFactory ;
47
47
48
48
/**
49
49
* PSR-7 stream factory
@@ -69,35 +69,22 @@ class Client implements HttpClient, HttpAsyncClient
69
69
/**
70
70
* Create new client
71
71
*
72
- * @param MessageFactory |null $messageFactory HTTP Message factory
73
- * @param StreamFactory|null $streamFactory HTTP Stream factory
74
- * @param array $options cURL options (see http://php.net/curl_setopt)
72
+ * @param ResponseFactory |null $responseFactory HTTP Response factory
73
+ * @param StreamFactory|null $streamFactory HTTP Stream factory
74
+ * @param array $options cURL options (see http://php.net/curl_setopt)
75
75
*
76
76
* @throws \LogicException If some factory not provided and php-http/discovery not installed
77
77
* @throws \Http\Discovery\Exception\NotFoundException If factory discovery failed.
78
78
*
79
79
* @since 1.0
80
80
*/
81
81
public function __construct (
82
- MessageFactory $ messageFactory = null ,
82
+ ResponseFactory $ responseFactory = null ,
83
83
StreamFactory $ streamFactory = null ,
84
84
array $ options = []
85
85
) {
86
- if (null === $ messageFactory ) {
87
- if (!class_exists (MessageFactoryDiscovery::class)) {
88
- throw new \LogicException (sprintf (self ::DEPENDENCY_MSG , 'messageFactory ' ));
89
- }
90
- $ messageFactory = MessageFactoryDiscovery::find ();
91
- }
92
- $ this ->messageFactory = $ messageFactory ;
93
-
94
- if (null === $ streamFactory ) {
95
- if (!class_exists (StreamFactoryDiscovery::class)) {
96
- throw new \LogicException (sprintf (self ::DEPENDENCY_MSG , 'streamFactory ' ));
97
- }
98
- $ streamFactory = StreamFactoryDiscovery::find ();
99
- }
100
- $ this ->streamFactory = $ streamFactory ;
86
+ $ this ->responseFactory = $ responseFactory ?: MessageFactoryDiscovery::find ();
87
+ $ this ->streamFactory = $ streamFactory ?: StreamFactoryDiscovery::find ();
101
88
102
89
$ this ->options = $ options ;
103
90
}
@@ -344,7 +331,7 @@ private function createResponseBuilder()
344
331
} catch (\InvalidArgumentException $ e ) {
345
332
throw new \RuntimeException ('Can not create "php://temp" stream. ' );
346
333
}
347
- $ response = $ this ->messageFactory ->createResponse (200 , null , [], $ body );
334
+ $ response = $ this ->responseFactory ->createResponse (200 , null , [], $ body );
348
335
349
336
return new ResponseBuilder ($ response );
350
337
}
0 commit comments