@@ -48,11 +48,11 @@ public function has(string $bucket, string $key): bool
48
48
}
49
49
50
50
/**
51
- * @param string|resource|callable|iterable $object
51
+ * @param string|resource|( callable(int): string) |iterable<string> $object
52
52
* @param array{
53
53
* ACL?: \AsyncAws\S3\Enum\ObjectCannedACL::*,
54
54
* CacheControl?: string,
55
- * ContentLength?: string ,
55
+ * ContentLength?: int ,
56
56
* ContentType?: string,
57
57
* Metadata?: array<string, string>,
58
58
* PartSize?: int,
@@ -144,6 +144,9 @@ public function upload(string $bucket, string $key, $object, array $options = []
144
144
]);
145
145
}
146
146
147
+ /**
148
+ * @param string|resource|(callable(int): string)|iterable<string> $object
149
+ */
147
150
private function getStream ($ object , int $ chunkSize ): FixedSizeStream
148
151
{
149
152
return FixedSizeStream::create (
@@ -152,6 +155,9 @@ private function getStream($object, int $chunkSize): FixedSizeStream
152
155
);
153
156
}
154
157
158
+ /**
159
+ * @param resource $buffer
160
+ */
155
161
private function doMultipartUpload (string $ bucket , string $ key , string $ uploadId , int $ partNumber , $ buffer ): CompletedPart
156
162
{
157
163
try {
@@ -171,7 +177,17 @@ private function doMultipartUpload(string $bucket, string $key, string $uploadId
171
177
}
172
178
}
173
179
174
- private function doSmallFileUpload (array $ options , string $ bucket , string $ key , $ object )
180
+ /**
181
+ * @param array{
182
+ * ACL?: \AsyncAws\S3\Enum\ObjectCannedACL::*,
183
+ * CacheControl?: string,
184
+ * ContentLength?: int,
185
+ * ContentType?: string,
186
+ * Metadata?: array<string, string>,
187
+ * } $options
188
+ * @param string|resource|(callable(int): string)|iterable<string> $object
189
+ */
190
+ private function doSmallFileUpload (array $ options , string $ bucket , string $ key , $ object ): void
175
191
{
176
192
$ this ->putObject (array_merge ($ options , [
177
193
'Bucket ' => $ bucket ,
0 commit comments