Skip to content

Commit 3b83afb

Browse files
committed
~ Consistent grammar and style in Migration.kt
1 parent c2cb529 commit 3b83afb

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

kotlinx-coroutines-core/common/src/flow/Migration.kt

+10-10
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ public fun <T> Flow<T>.publishOn(context: CoroutineContext): Flow<T> = noImpl()
9797
* Opposed to subscribeOn, it it **possible** to use multiple `flowOn` operators in the one flow
9898
* @suppress
9999
*/
100-
@Deprecated(message = "Use flowOn instead", level = DeprecationLevel.ERROR)
100+
@Deprecated(message = "Use 'flowOn' instead", level = DeprecationLevel.ERROR)
101101
public fun <T> Flow<T>.subscribeOn(context: CoroutineContext): Flow<T> = noImpl()
102102

103103
/**
@@ -149,7 +149,7 @@ public fun <T> Flow<T>.onErrorResumeNext(fallback: Flow<T>): Flow<T> = noImpl()
149149
* @suppress
150150
*/
151151
@Deprecated(
152-
message = "Use launchIn with onEach, onCompletion and catch operators instead",
152+
message = "Use 'launchIn' with 'onEach', 'onCompletion' and 'catch' instead",
153153
level = DeprecationLevel.ERROR
154154
)
155155
public fun <T> Flow<T>.subscribe(): Unit = noImpl()
@@ -159,7 +159,7 @@ public fun <T> Flow<T>.subscribe(): Unit = noImpl()
159159
* @suppress
160160
*/
161161
@Deprecated(
162-
message = "Use launchIn with onEach, onCompletion and catch operators instead",
162+
message = "Use 'launchIn' with 'onEach', 'onCompletion' and 'catch' instead",
163163
level = DeprecationLevel.ERROR
164164
)public fun <T> Flow<T>.subscribe(onEach: suspend (T) -> Unit): Unit = noImpl()
165165

@@ -168,7 +168,7 @@ public fun <T> Flow<T>.subscribe(): Unit = noImpl()
168168
* @suppress
169169
*/
170170
@Deprecated(
171-
message = "Use launchIn with onEach, onCompletion and catch operators instead",
171+
message = "Use 'launchIn' with 'onEach', 'onCompletion' and 'catch' instead",
172172
level = DeprecationLevel.ERROR
173173
)public fun <T> Flow<T>.subscribe(onEach: suspend (T) -> Unit, onError: suspend (Throwable) -> Unit): Unit = noImpl()
174174

@@ -179,7 +179,7 @@ public fun <T> Flow<T>.subscribe(): Unit = noImpl()
179179
*/
180180
@Deprecated(
181181
level = DeprecationLevel.ERROR,
182-
message = "Flow analogue is named flatMapConcat",
182+
message = "Flow analogue is 'flatMapConcat'",
183183
replaceWith = ReplaceWith("flatMapConcat(mapper)")
184184
)
185185
public fun <T, R> Flow<T>.flatMap(mapper: suspend (T) -> Flow<R>): Flow<R> = noImpl()
@@ -431,7 +431,7 @@ public fun <T, R> Flow<T>.switchMap(transform: suspend (value: T) -> Flow<R>): F
431431

432432
@Deprecated(
433433
level = DeprecationLevel.ERROR,
434-
message = "Flow analogue of 'publish' is 'shareIn' operator. \n" +
434+
message = "Flow analogue of 'publish()' is 'shareIn'. \n" +
435435
"publish().connect() is the default strategy (no extra call is needed), \n" +
436436
"publish().autoConnect() translates to 'started = SharingStared.Lazily' argument, \n" +
437437
"publish().refCount() translates to 'started = SharingStared.WhileSubscribed()' argument.",
@@ -441,7 +441,7 @@ public fun <T> Flow<T>.publish(): Flow<T> = noImpl()
441441

442442
@Deprecated(
443443
level = DeprecationLevel.ERROR,
444-
message = "Flow analogue of 'publish(bufferSize)' is 'buffer' operator followed by 'shareIn'. \n" +
444+
message = "Flow analogue of 'publish(bufferSize)' is 'buffer' followed by 'shareIn'. \n" +
445445
"publish().connect() is the default strategy (no extra call is needed), \n" +
446446
"publish().autoConnect() translates to 'started = SharingStared.Lazily' argument, \n" +
447447
"publish().refCount() translates to 'started = SharingStared.WhileSubscribed()' argument.",
@@ -451,7 +451,7 @@ public fun <T> Flow<T>.publish(bufferSize: Int): Flow<T> = noImpl()
451451

452452
@Deprecated(
453453
level = DeprecationLevel.ERROR,
454-
message = "Flow analogue of 'replay()' is 'shareIn' operator with unlimited replay. \n" +
454+
message = "Flow analogue of 'replay()' is 'shareIn' with unlimited replay. \n" +
455455
"replay().connect() is the default strategy (no extra call is needed), \n" +
456456
"replay().autoConnect() translates to 'started = SharingStared.Lazily' argument, \n" +
457457
"replay().refCount() translates to 'started = SharingStared.WhileSubscribed()' argument.",
@@ -461,7 +461,7 @@ public fun <T> Flow<T>.replay(): Flow<T> = noImpl()
461461

462462
@Deprecated(
463463
level = DeprecationLevel.ERROR,
464-
message = "Flow analogue of 'replay(bufferSize)' is 'shareIn' operator with the specified replay parameter. \n" +
464+
message = "Flow analogue of 'replay(bufferSize)' is 'shareIn' with the specified replay parameter. \n" +
465465
"replay().connect() is the default strategy (no extra call is needed), \n" +
466466
"replay().autoConnect() translates to 'started = SharingStared.Lazily' argument, \n" +
467467
"replay().refCount() translates to 'started = SharingStared.WhileSubscribed()' argument.",
@@ -471,7 +471,7 @@ public fun <T> Flow<T>.replay(bufferSize: Int): Flow<T> = noImpl()
471471

472472
@Deprecated(
473473
level = DeprecationLevel.ERROR,
474-
message = "Flow analogue of 'cache()' is 'shareIn' operator with unlimited replay and 'started = SharingStared.Lazily' argument'",
474+
message = "Flow analogue of 'cache()' is 'shareIn' with unlimited replay and 'started = SharingStared.Lazily' argument'",
475475
replaceWith = ReplaceWith("this.shareIn(scope, Int.MAX_VALUE, started = SharingStared.Lazily)")
476476
)
477477
public fun <T> Flow<T>.cache(): Flow<T> = noImpl()

0 commit comments

Comments
 (0)