Skip to content

Commit b45a4e6

Browse files
author
yiguang
committed
fix: support image async stream
1 parent a3a19cf commit b45a4e6

File tree

1 file changed

+5
-5
lines changed
  • volcenginesdkarkruntime/resources/images

1 file changed

+5
-5
lines changed

volcenginesdkarkruntime/resources/images/images.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
)
2828
from ...types.images.image_gen_stream_event import ImageGenStreamEvent
2929
from ..._types import Body, Query, Headers
30-
from ..._streaming import Stream
30+
from ..._streaming import Stream, AsyncStream
3131
from ...types.images.images import OptimizePromptOptions
3232

3333

@@ -222,7 +222,7 @@ async def generate(
222222
sequential_image_generation_options: SequentialImageGenerationOptions
223223
| None = None,
224224
stream: Literal[True],
225-
) -> Stream[ImageGenStreamEvent]: ...
225+
) -> AsyncStream[ImageGenStreamEvent]: ...
226226

227227
@overload
228228
async def generate(
@@ -246,7 +246,7 @@ async def generate(
246246
sequential_image_generation_options: SequentialImageGenerationOptions
247247
| None = None,
248248
stream: bool,
249-
) -> ImagesResponse | Stream[ImageGenStreamEvent]: ...
249+
) -> ImagesResponse | AsyncStream[ImageGenStreamEvent]: ...
250250

251251
@async_apikey_required
252252
async def generate(
@@ -270,7 +270,7 @@ async def generate(
270270
sequential_image_generation_options: SequentialImageGenerationOptions
271271
| None = None,
272272
stream: Optional[Literal[False]] | Literal[True] | NotGiven = NOT_GIVEN,
273-
) -> ImagesResponse | Stream[ImageGenStreamEvent]:
273+
) -> ImagesResponse | AsyncStream[ImageGenStreamEvent]:
274274
return await self._post(
275275
"/images/generations",
276276
body={
@@ -304,5 +304,5 @@ async def generate(
304304
),
305305
cast_to=ImagesResponse,
306306
stream=stream or False,
307-
stream_cls=Stream[ImageGenStreamEvent],
307+
stream_cls=AsyncStream[ImageGenStreamEvent],
308308
)

0 commit comments

Comments
 (0)