Committed by
GitHub
Specify default values for StreamTextOptions and streamText (#688)
正在显示
3 个修改的文件
包含
10 行增加
和
5 行删除
.changeset/kind-plums-report.md
0 → 100644
| @@ -34,12 +34,12 @@ data class StreamTextOptions( | @@ -34,12 +34,12 @@ data class StreamTextOptions( | ||
| 34 | val attributes: Map<String, String> = emptyMap(), | 34 | val attributes: Map<String, String> = emptyMap(), |
| 35 | val streamId: String = UUID.randomUUID().toString(), | 35 | val streamId: String = UUID.randomUUID().toString(), |
| 36 | val destinationIdentities: List<Participant.Identity> = emptyList(), | 36 | val destinationIdentities: List<Participant.Identity> = emptyList(), |
| 37 | - val operationType: TextStreamInfo.OperationType, | 37 | + val operationType: TextStreamInfo.OperationType = TextStreamInfo.OperationType.CREATE, |
| 38 | val version: Int = 0, | 38 | val version: Int = 0, |
| 39 | val attachedStreamIds: List<String> = emptyList(), | 39 | val attachedStreamIds: List<String> = emptyList(), |
| 40 | val replyToStreamId: String? = null, | 40 | val replyToStreamId: String? = null, |
| 41 | /** | 41 | /** |
| 42 | - * The total exact size in bytes, if known. | 42 | + * The total exact size in bytes when encoded to UTF-8, if known. |
| 43 | */ | 43 | */ |
| 44 | val totalSize: Long? = null, | 44 | val totalSize: Long? = null, |
| 45 | ) | 45 | ) |
| @@ -35,12 +35,12 @@ import javax.inject.Inject | @@ -35,12 +35,12 @@ import javax.inject.Inject | ||
| 35 | 35 | ||
| 36 | interface OutgoingDataStreamManager { | 36 | interface OutgoingDataStreamManager { |
| 37 | /** | 37 | /** |
| 38 | - * Start sending a stream of text | 38 | + * Start sending a stream of text. Call [TextStreamSender.close] when finished sending. |
| 39 | */ | 39 | */ |
| 40 | - suspend fun streamText(options: StreamTextOptions): TextStreamSender | 40 | + suspend fun streamText(options: StreamTextOptions = StreamTextOptions()): TextStreamSender |
| 41 | 41 | ||
| 42 | /** | 42 | /** |
| 43 | - * Start sending a stream of bytes | 43 | + * Start sending a stream of bytes. Call [ByteStreamSender.close] when finished sending. |
| 44 | */ | 44 | */ |
| 45 | suspend fun streamBytes(options: StreamBytesOptions): ByteStreamSender | 45 | suspend fun streamBytes(options: StreamBytesOptions): ByteStreamSender |
| 46 | } | 46 | } |
-
请 注册 或 登录 后发表评论