@@ -15,10 +15,10 @@ package com.google.firebase.functions
15
15
16
16
import androidx.annotation.VisibleForTesting
17
17
import com.google.android.gms.tasks.Task
18
- import kotlinx.coroutines.flow.Flow
19
- import kotlinx.coroutines.reactive.asFlow
20
18
import java.net.URL
21
19
import java.util.concurrent.TimeUnit
20
+ import kotlinx.coroutines.flow.Flow
21
+ import kotlinx.coroutines.reactive.asFlow
22
22
import org.reactivestreams.Publisher
23
23
24
24
/* * A reference to a particular Callable HTTPS trigger in Cloud Functions. */
@@ -205,8 +205,8 @@ public class HttpsCallableReference {
205
205
* Instance ID the next time you call this method.
206
206
*
207
207
* @param data Parameters to pass to the endpoint. Defaults to `null` if not provided.
208
- * @return [Flow] that will emit intermediate data, and the final result, as it is generated
209
- * by the function.
208
+ * @return [Flow] that will emit intermediate data, and the final result, as it is generated by
209
+ * the function.
210
210
* @see org.json.JSONArray
211
211
*
212
212
* @see org.json.JSONObject
@@ -216,8 +216,7 @@ public class HttpsCallableReference {
216
216
* @see FirebaseFunctionsException
217
217
*/
218
218
@JvmOverloads
219
- public fun streamAsFlow (data : Any? = null): Flow <StreamResponse > =
220
- stream(data).asFlow()
219
+ public fun streamAsFlow (data : Any? = null): Flow <StreamResponse > = stream(data).asFlow()
221
220
222
221
/* *
223
222
* Changes the timeout for calls from this instance of Functions. The default is 60 seconds.
0 commit comments