CrackMe.apk
Download file
package kotlinx.coroutines.flow;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
import kotlin.Deprecated;
import kotlin.DeprecationLevel;
import kotlin.Metadata;
import kotlin.ReplaceWith;
import kotlin.Unit;
import kotlin.collections.IndexedValue;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.CoroutineContext;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.functions.Function1;
import kotlin.jvm.functions.Function2;
import kotlin.jvm.functions.Function3;
import kotlin.jvm.functions.Function4;
import kotlin.jvm.functions.Function5;
import kotlin.jvm.functions.Function6;
import kotlin.jvm.functions.Function7;
import kotlin.ranges.IntRange;
import kotlin.ranges.LongRange;
import kotlin.sequences.Sequence;
import kotlin.time.Duration;
import kotlinx.coroutines.CoroutineScope;
import kotlinx.coroutines.Job;
import kotlinx.coroutines.channels.BroadcastChannel;
import kotlinx.coroutines.channels.BufferOverflow;
import kotlinx.coroutines.channels.ProducerScope;
import kotlinx.coroutines.channels.ReceiveChannel;
@Metadata(d1 = {"kotlinx/coroutines/flow/FlowKt__BuildersKt", "kotlinx/coroutines/flow/FlowKt__ChannelsKt", "kotlinx/coroutines/flow/FlowKt__CollectKt", "kotlinx/coroutines/flow/FlowKt__CollectionKt", "kotlinx/coroutines/flow/FlowKt__ContextKt", "kotlinx/coroutines/flow/FlowKt__CountKt", "kotlinx/coroutines/flow/FlowKt__DelayKt", "kotlinx/coroutines/flow/FlowKt__DistinctKt", "kotlinx/coroutines/flow/FlowKt__EmittersKt", "kotlinx/coroutines/flow/FlowKt__ErrorsKt", "kotlinx/coroutines/flow/FlowKt__LimitKt", "kotlinx/coroutines/flow/FlowKt__MergeKt", "kotlinx/coroutines/flow/FlowKt__MigrationKt", "kotlinx/coroutines/flow/FlowKt__ReduceKt", "kotlinx/coroutines/flow/FlowKt__ShareKt", "kotlinx/coroutines/flow/FlowKt__TransformKt", "kotlinx/coroutines/flow/FlowKt__ZipKt"}, k = 4, mv = {1, 6, 0}, xi = 48)
public final class FlowKt {
public static final String DEFAULT_CONCURRENCY_PROPERTY_NAME = "kotlinx.coroutines.flow.defaultConcurrency";
public static final <T> Flow<T> asFlow(Iterable<? extends T> iterable) {
return FlowKt__BuildersKt.asFlow(iterable);
}
public static final <T> Flow<T> asFlow(Iterator<? extends T> it) {
return FlowKt__BuildersKt.asFlow(it);
}
public static final <T> Flow<T> asFlow(Function0<? extends T> function0) {
return FlowKt__BuildersKt.asFlow(function0);
}
public static final <T> Flow<T> asFlow(Function1<? super Continuation<? super T>, ? extends Object> function1) {
return FlowKt__BuildersKt.asFlow(function1);
}
public static final Flow<Integer> asFlow(IntRange intRange) {
return FlowKt__BuildersKt.asFlow(intRange);
}
public static final Flow<Long> asFlow(LongRange longRange) {
return FlowKt__BuildersKt.asFlow(longRange);
}
public static final <T> Flow<T> asFlow(Sequence<? extends T> sequence) {
return FlowKt__BuildersKt.asFlow(sequence);
}
@Deprecated(level = DeprecationLevel.WARNING, message = "'BroadcastChannel' is obsolete and all corresponding operators are deprecated in the favour of StateFlow and SharedFlow")
public static final <T> Flow<T> asFlow(BroadcastChannel<T> broadcastChannel) {
return FlowKt__ChannelsKt.asFlow(broadcastChannel);
}
public static final Flow<Integer> asFlow(int[] iArr) {
return FlowKt__BuildersKt.asFlow(iArr);
}
public static final Flow<Long> asFlow(long[] jArr) {
return FlowKt__BuildersKt.asFlow(jArr);
}
public static final <T> Flow<T> asFlow(T[] tArr) {
return FlowKt__BuildersKt.asFlow(tArr);
}
public static final <T> SharedFlow<T> asSharedFlow(MutableSharedFlow<T> mutableSharedFlow) {
return FlowKt__ShareKt.asSharedFlow(mutableSharedFlow);
}
public static final <T> StateFlow<T> asStateFlow(MutableStateFlow<T> mutableStateFlow) {
return FlowKt__ShareKt.asStateFlow(mutableStateFlow);
}
public static final <T> Flow<T> buffer(Flow<? extends T> flow, int i, BufferOverflow bufferOverflow) {
return FlowKt__ContextKt.buffer(flow, i, bufferOverflow);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'cache()' is 'shareIn' with unlimited replay and 'started = SharingStared.Lazily' argument'", replaceWith = @ReplaceWith(expression = "this.shareIn(scope, Int.MAX_VALUE, started = SharingStared.Lazily)", imports = {}))
public static final <T> Flow<T> cache(Flow<? extends T> flow) {
return FlowKt__MigrationKt.cache(flow);
}
public static final <T> Flow<T> callbackFlow(Function2<? super ProducerScope<? super T>, ? super Continuation<? super Unit>, ? extends Object> function2) {
return FlowKt__BuildersKt.callbackFlow(function2);
}
public static final <T> Flow<T> cancellable(Flow<? extends T> flow) {
return FlowKt__ContextKt.cancellable(flow);
}
/* renamed from: catch reason: not valid java name */
public static final <T> Flow<T> m1818catch(Flow<? extends T> flow, Function3<? super FlowCollector<? super T>, ? super Throwable, ? super Continuation<? super Unit>, ? extends Object> function3) {
return FlowKt__ErrorsKt.m1825catch(flow, function3);
}
public static final <T> Object catchImpl(Flow<? extends T> flow, FlowCollector<? super T> flowCollector, Continuation<? super Throwable> continuation) {
return FlowKt__ErrorsKt.catchImpl(flow, flowCollector, continuation);
}
public static final <T> Flow<T> channelFlow(Function2<? super ProducerScope<? super T>, ? super Continuation<? super Unit>, ? extends Object> function2) {
return FlowKt__BuildersKt.channelFlow(function2);
}
public static final Object collect(Flow<?> flow, Continuation<? super Unit> continuation) {
return FlowKt__CollectKt.collect(flow, continuation);
}
public static final <T> Object collectIndexed(Flow<? extends T> flow, Function3<? super Integer, ? super T, ? super Continuation<? super Unit>, ? extends Object> function3, Continuation<? super Unit> continuation) {
return FlowKt__CollectKt.collectIndexed(flow, function3, continuation);
}
public static final <T> Object collectLatest(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Unit>, ? extends Object> function2, Continuation<? super Unit> continuation) {
return FlowKt__CollectKt.collectLatest(flow, function2, continuation);
}
public static final <T> Object collectWhile(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Boolean>, ? extends Object> function2, Continuation<? super Unit> continuation) {
return FlowKt__LimitKt.collectWhile(flow, function2, continuation);
}
public static final <T1, T2, R> Flow<R> combine(Flow<? extends T1> flow, Flow<? extends T2> flow2, Function3<? super T1, ? super T2, ? super Continuation<? super R>, ? extends Object> function3) {
return FlowKt__ZipKt.combine(flow, flow2, function3);
}
public static final <T1, T2, T3, R> Flow<R> combine(Flow<? extends T1> flow, Flow<? extends T2> flow2, Flow<? extends T3> flow3, Function4<? super T1, ? super T2, ? super T3, ? super Continuation<? super R>, ? extends Object> function4) {
return FlowKt__ZipKt.combine(flow, flow2, flow3, function4);
}
public static final <T1, T2, T3, T4, R> Flow<R> combine(Flow<? extends T1> flow, Flow<? extends T2> flow2, Flow<? extends T3> flow3, Flow<? extends T4> flow4, Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super Continuation<? super R>, ? extends Object> function5) {
return FlowKt__ZipKt.combine(flow, flow2, flow3, flow4, function5);
}
public static final <T1, T2, T3, T4, T5, R> Flow<R> combine(Flow<? extends T1> flow, Flow<? extends T2> flow2, Flow<? extends T3> flow3, Flow<? extends T4> flow4, Flow<? extends T5> flow5, Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super Continuation<? super R>, ? extends Object> function6) {
return FlowKt__ZipKt.combine(flow, flow2, flow3, flow4, flow5, function6);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'combineLatest' is 'combine'", replaceWith = @ReplaceWith(expression = "this.combine(other, transform)", imports = {}))
public static final <T1, T2, R> Flow<R> combineLatest(Flow<? extends T1> flow, Flow<? extends T2> flow2, Function3<? super T1, ? super T2, ? super Continuation<? super R>, ? extends Object> function3) {
return FlowKt__MigrationKt.combineLatest(flow, flow2, function3);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'combineLatest' is 'combine'", replaceWith = @ReplaceWith(expression = "combine(this, other, other2, transform)", imports = {}))
public static final <T1, T2, T3, R> Flow<R> combineLatest(Flow<? extends T1> flow, Flow<? extends T2> flow2, Flow<? extends T3> flow3, Function4<? super T1, ? super T2, ? super T3, ? super Continuation<? super R>, ? extends Object> function4) {
return FlowKt__MigrationKt.combineLatest(flow, flow2, flow3, function4);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'combineLatest' is 'combine'", replaceWith = @ReplaceWith(expression = "combine(this, other, other2, other3, transform)", imports = {}))
public static final <T1, T2, T3, T4, R> Flow<R> combineLatest(Flow<? extends T1> flow, Flow<? extends T2> flow2, Flow<? extends T3> flow3, Flow<? extends T4> flow4, Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super Continuation<? super R>, ? extends Object> function5) {
return FlowKt__MigrationKt.combineLatest(flow, flow2, flow3, flow4, function5);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'combineLatest' is 'combine'", replaceWith = @ReplaceWith(expression = "combine(this, other, other2, other3, transform)", imports = {}))
public static final <T1, T2, T3, T4, T5, R> Flow<R> combineLatest(Flow<? extends T1> flow, Flow<? extends T2> flow2, Flow<? extends T3> flow3, Flow<? extends T4> flow4, Flow<? extends T5> flow5, Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super Continuation<? super R>, ? extends Object> function6) {
return FlowKt__MigrationKt.combineLatest(flow, flow2, flow3, flow4, flow5, function6);
}
public static final <T1, T2, R> Flow<R> combineTransform(Flow<? extends T1> flow, Flow<? extends T2> flow2, Function4<? super FlowCollector<? super R>, ? super T1, ? super T2, ? super Continuation<? super Unit>, ? extends Object> function4) {
return FlowKt__ZipKt.combineTransform(flow, flow2, function4);
}
public static final <T1, T2, T3, R> Flow<R> combineTransform(Flow<? extends T1> flow, Flow<? extends T2> flow2, Flow<? extends T3> flow3, Function5<? super FlowCollector<? super R>, ? super T1, ? super T2, ? super T3, ? super Continuation<? super Unit>, ? extends Object> function5) {
return FlowKt__ZipKt.combineTransform(flow, flow2, flow3, function5);
}
public static final <T1, T2, T3, T4, R> Flow<R> combineTransform(Flow<? extends T1> flow, Flow<? extends T2> flow2, Flow<? extends T3> flow3, Flow<? extends T4> flow4, Function6<? super FlowCollector<? super R>, ? super T1, ? super T2, ? super T3, ? super T4, ? super Continuation<? super Unit>, ? extends Object> function6) {
return FlowKt__ZipKt.combineTransform(flow, flow2, flow3, flow4, function6);
}
public static final <T1, T2, T3, T4, T5, R> Flow<R> combineTransform(Flow<? extends T1> flow, Flow<? extends T2> flow2, Flow<? extends T3> flow3, Flow<? extends T4> flow4, Flow<? extends T5> flow5, Function7<? super FlowCollector<? super R>, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super Continuation<? super Unit>, ? extends Object> function7) {
return FlowKt__ZipKt.combineTransform(flow, flow2, flow3, flow4, flow5, function7);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'compose' is 'let'", replaceWith = @ReplaceWith(expression = "let(transformer)", imports = {}))
public static final <T, R> Flow<R> compose(Flow<? extends T> flow, Function1<? super Flow<? extends T>, ? extends Flow<? extends R>> function1) {
return FlowKt__MigrationKt.compose(flow, function1);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'concatMap' is 'flatMapConcat'", replaceWith = @ReplaceWith(expression = "flatMapConcat(mapper)", imports = {}))
public static final <T, R> Flow<R> concatMap(Flow<? extends T> flow, Function1<? super T, ? extends Flow<? extends R>> function1) {
return FlowKt__MigrationKt.concatMap(flow, function1);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'concatWith' is 'onCompletion'. Use 'onCompletion { emit(value) }'", replaceWith = @ReplaceWith(expression = "onCompletion { emit(value) }", imports = {}))
public static final <T> Flow<T> concatWith(Flow<? extends T> flow, T t) {
return FlowKt__MigrationKt.concatWith(flow, t);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'concatWith' is 'onCompletion'. Use 'onCompletion { if (it == null) emitAll(other) }'", replaceWith = @ReplaceWith(expression = "onCompletion { if (it == null) emitAll(other) }", imports = {}))
public static final <T> Flow<T> concatWith(Flow<? extends T> flow, Flow<? extends T> flow2) {
return FlowKt__MigrationKt.concatWith(flow, flow2);
}
public static final <T> Flow<T> conflate(Flow<? extends T> flow) {
return FlowKt__ContextKt.conflate(flow);
}
public static final <T> Flow<T> consumeAsFlow(ReceiveChannel<? extends T> receiveChannel) {
return FlowKt__ChannelsKt.consumeAsFlow(receiveChannel);
}
public static final <T> Object count(Flow<? extends T> flow, Continuation<? super Integer> continuation) {
return FlowKt__CountKt.count(flow, continuation);
}
public static final <T> Object count(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Boolean>, ? extends Object> function2, Continuation<? super Integer> continuation) {
return FlowKt__CountKt.count(flow, function2, continuation);
}
public static final <T> Flow<T> debounce(Flow<? extends T> flow, long j) {
return FlowKt__DelayKt.debounce(flow, j);
}
public static final <T> Flow<T> debounce(Flow<? extends T> flow, Function1<? super T, Long> function1) {
return FlowKt__DelayKt.debounce(flow, function1);
}
/* renamed from: debounce-HG0u8IE reason: not valid java name */
public static final <T> Flow<T> m1819debounceHG0u8IE(Flow<? extends T> flow, long j) {
return FlowKt__DelayKt.m1821debounceHG0u8IE(flow, j);
}
public static final <T> Flow<T> debounceDuration(Flow<? extends T> flow, Function1<? super T, Duration> function1) {
return FlowKt__DelayKt.debounceDuration(flow, function1);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Use 'onEach { delay(timeMillis) }'", replaceWith = @ReplaceWith(expression = "onEach { delay(timeMillis) }", imports = {}))
public static final <T> Flow<T> delayEach(Flow<? extends T> flow, long j) {
return FlowKt__MigrationKt.delayEach(flow, j);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Use 'onStart { delay(timeMillis) }'", replaceWith = @ReplaceWith(expression = "onStart { delay(timeMillis) }", imports = {}))
public static final <T> Flow<T> delayFlow(Flow<? extends T> flow, long j) {
return FlowKt__MigrationKt.delayFlow(flow, j);
}
public static final <T> Flow<T> distinctUntilChanged(Flow<? extends T> flow) {
return FlowKt__DistinctKt.distinctUntilChanged(flow);
}
public static final <T> Flow<T> distinctUntilChanged(Flow<? extends T> flow, Function2<? super T, ? super T, Boolean> function2) {
return FlowKt__DistinctKt.distinctUntilChanged(flow, function2);
}
public static final <T, K> Flow<T> distinctUntilChangedBy(Flow<? extends T> flow, Function1<? super T, ? extends K> function1) {
return FlowKt__DistinctKt.distinctUntilChangedBy(flow, function1);
}
public static final <T> Flow<T> drop(Flow<? extends T> flow, int i) {
return FlowKt__LimitKt.drop(flow, i);
}
public static final <T> Flow<T> dropWhile(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Boolean>, ? extends Object> function2) {
return FlowKt__LimitKt.dropWhile(flow, function2);
}
public static final <T> Object emitAll(FlowCollector<? super T> flowCollector, ReceiveChannel<? extends T> receiveChannel, Continuation<? super Unit> continuation) {
return FlowKt__ChannelsKt.emitAll(flowCollector, receiveChannel, continuation);
}
public static final <T> Object emitAll(FlowCollector<? super T> flowCollector, Flow<? extends T> flow, Continuation<? super Unit> continuation) {
return FlowKt__CollectKt.emitAll(flowCollector, flow, continuation);
}
public static final <T> Flow<T> emptyFlow() {
return FlowKt__BuildersKt.emptyFlow();
}
public static final void ensureActive(FlowCollector<?> flowCollector) {
FlowKt__EmittersKt.ensureActive(flowCollector);
}
public static final <T> Flow<T> filter(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Boolean>, ? extends Object> function2) {
return FlowKt__TransformKt.filter(flow, function2);
}
public static final <T> Flow<T> filterNot(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Boolean>, ? extends Object> function2) {
return FlowKt__TransformKt.filterNot(flow, function2);
}
public static final <T> Flow<T> filterNotNull(Flow<? extends T> flow) {
return FlowKt__TransformKt.filterNotNull(flow);
}
public static final <T> Object first(Flow<? extends T> flow, Continuation<? super T> continuation) {
return FlowKt__ReduceKt.first(flow, continuation);
}
public static final <T> Object first(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Boolean>, ? extends Object> function2, Continuation<? super T> continuation) {
return FlowKt__ReduceKt.first(flow, function2, continuation);
}
public static final <T> Object firstOrNull(Flow<? extends T> flow, Continuation<? super T> continuation) {
return FlowKt__ReduceKt.firstOrNull(flow, continuation);
}
public static final <T> Object firstOrNull(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Boolean>, ? extends Object> function2, Continuation<? super T> continuation) {
return FlowKt__ReduceKt.firstOrNull(flow, function2, continuation);
}
public static final ReceiveChannel<Unit> fixedPeriodTicker(CoroutineScope coroutineScope, long j, long j2) {
return FlowKt__DelayKt.fixedPeriodTicker(coroutineScope, j, j2);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue is 'flatMapConcat'", replaceWith = @ReplaceWith(expression = "flatMapConcat(mapper)", imports = {}))
public static final <T, R> Flow<R> flatMap(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Flow<? extends R>>, ? extends Object> function2) {
return FlowKt__MigrationKt.flatMap(flow, function2);
}
public static final <T, R> Flow<R> flatMapConcat(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Flow<? extends R>>, ? extends Object> function2) {
return FlowKt__MergeKt.flatMapConcat(flow, function2);
}
public static final <T, R> Flow<R> flatMapLatest(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Flow<? extends R>>, ? extends Object> function2) {
return FlowKt__MergeKt.flatMapLatest(flow, function2);
}
public static final <T, R> Flow<R> flatMapMerge(Flow<? extends T> flow, int i, Function2<? super T, ? super Continuation<? super Flow<? extends R>>, ? extends Object> function2) {
return FlowKt__MergeKt.flatMapMerge(flow, i, function2);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'flatten' is 'flattenConcat'", replaceWith = @ReplaceWith(expression = "flattenConcat()", imports = {}))
public static final <T> Flow<T> flatten(Flow<? extends Flow<? extends T>> flow) {
return FlowKt__MigrationKt.flatten(flow);
}
public static final <T> Flow<T> flattenConcat(Flow<? extends Flow<? extends T>> flow) {
return FlowKt__MergeKt.flattenConcat(flow);
}
public static final <T> Flow<T> flattenMerge(Flow<? extends Flow<? extends T>> flow, int i) {
return FlowKt__MergeKt.flattenMerge(flow, i);
}
public static final <T> Flow<T> flow(Function2<? super FlowCollector<? super T>, ? super Continuation<? super Unit>, ? extends Object> function2) {
return FlowKt__BuildersKt.flow(function2);
}
public static final <T1, T2, R> Flow<R> flowCombine(Flow<? extends T1> flow, Flow<? extends T2> flow2, Function3<? super T1, ? super T2, ? super Continuation<? super R>, ? extends Object> function3) {
return FlowKt__ZipKt.flowCombine(flow, flow2, function3);
}
public static final <T1, T2, R> Flow<R> flowCombineTransform(Flow<? extends T1> flow, Flow<? extends T2> flow2, Function4<? super FlowCollector<? super R>, ? super T1, ? super T2, ? super Continuation<? super Unit>, ? extends Object> function4) {
return FlowKt__ZipKt.flowCombineTransform(flow, flow2, function4);
}
public static final <T> Flow<T> flowOf(T t) {
return FlowKt__BuildersKt.flowOf(t);
}
public static final <T> Flow<T> flowOf(T... tArr) {
return FlowKt__BuildersKt.flowOf(tArr);
}
public static final <T> Flow<T> flowOn(Flow<? extends T> flow, CoroutineContext coroutineContext) {
return FlowKt__ContextKt.flowOn(flow, coroutineContext);
}
public static final <T, R> Object fold(Flow<? extends T> flow, R r, Function3<? super R, ? super T, ? super Continuation<? super R>, ? extends Object> function3, Continuation<? super R> continuation) {
return FlowKt__ReduceKt.fold(flow, r, function3, continuation);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'forEach' is 'collect'", replaceWith = @ReplaceWith(expression = "collect(action)", imports = {}))
public static final <T> void forEach(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Unit>, ? extends Object> function2) {
FlowKt__MigrationKt.forEach(flow, function2);
}
public static final int getDEFAULT_CONCURRENCY() {
return FlowKt__MergeKt.getDEFAULT_CONCURRENCY();
}
public static final <T> Object last(Flow<? extends T> flow, Continuation<? super T> continuation) {
return FlowKt__ReduceKt.last(flow, continuation);
}
public static final <T> Object lastOrNull(Flow<? extends T> flow, Continuation<? super T> continuation) {
return FlowKt__ReduceKt.lastOrNull(flow, continuation);
}
public static final <T> Job launchIn(Flow<? extends T> flow, CoroutineScope coroutineScope) {
return FlowKt__CollectKt.launchIn(flow, coroutineScope);
}
public static final <T, R> Flow<R> map(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super R>, ? extends Object> function2) {
return FlowKt__TransformKt.map(flow, function2);
}
public static final <T, R> Flow<R> mapLatest(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super R>, ? extends Object> function2) {
return FlowKt__MergeKt.mapLatest(flow, function2);
}
public static final <T, R> Flow<R> mapNotNull(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super R>, ? extends Object> function2) {
return FlowKt__TransformKt.mapNotNull(flow, function2);
}
public static final <T> Flow<T> merge(Iterable<? extends Flow<? extends T>> iterable) {
return FlowKt__MergeKt.merge(iterable);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'merge' is 'flattenConcat'", replaceWith = @ReplaceWith(expression = "flattenConcat()", imports = {}))
public static final <T> Flow<T> merge(Flow<? extends Flow<? extends T>> flow) {
return FlowKt__MigrationKt.merge(flow);
}
public static final <T> Flow<T> merge(Flow<? extends T>... flowArr) {
return FlowKt__MergeKt.merge(flowArr);
}
public static final Void noImpl() {
return FlowKt__MigrationKt.noImpl();
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Collect flow in the desired context instead")
public static final <T> Flow<T> observeOn(Flow<? extends T> flow, CoroutineContext coroutineContext) {
return FlowKt__MigrationKt.observeOn(flow, coroutineContext);
}
public static final <T> Flow<T> onCompletion(Flow<? extends T> flow, Function3<? super FlowCollector<? super T>, ? super Throwable, ? super Continuation<? super Unit>, ? extends Object> function3) {
return FlowKt__EmittersKt.onCompletion(flow, function3);
}
public static final <T> Flow<T> onEach(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Unit>, ? extends Object> function2) {
return FlowKt__TransformKt.onEach(flow, function2);
}
public static final <T> Flow<T> onEmpty(Flow<? extends T> flow, Function2<? super FlowCollector<? super T>, ? super Continuation<? super Unit>, ? extends Object> function2) {
return FlowKt__EmittersKt.onEmpty(flow, function2);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'onErrorXxx' is 'catch'. Use 'catch { emitAll(fallback) }'", replaceWith = @ReplaceWith(expression = "catch { emitAll(fallback) }", imports = {}))
public static final <T> Flow<T> onErrorResume(Flow<? extends T> flow, Flow<? extends T> flow2) {
return FlowKt__MigrationKt.onErrorResume(flow, flow2);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'onErrorXxx' is 'catch'. Use 'catch { emitAll(fallback) }'", replaceWith = @ReplaceWith(expression = "catch { emitAll(fallback) }", imports = {}))
public static final <T> Flow<T> onErrorResumeNext(Flow<? extends T> flow, Flow<? extends T> flow2) {
return FlowKt__MigrationKt.onErrorResumeNext(flow, flow2);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'onErrorXxx' is 'catch'. Use 'catch { emit(fallback) }'", replaceWith = @ReplaceWith(expression = "catch { emit(fallback) }", imports = {}))
public static final <T> Flow<T> onErrorReturn(Flow<? extends T> flow, T t) {
return FlowKt__MigrationKt.onErrorReturn(flow, t);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'onErrorXxx' is 'catch'. Use 'catch { e -> if (predicate(e)) emit(fallback) else throw e }'", replaceWith = @ReplaceWith(expression = "catch { e -> if (predicate(e)) emit(fallback) else throw e }", imports = {}))
public static final <T> Flow<T> onErrorReturn(Flow<? extends T> flow, T t, Function1<? super Throwable, Boolean> function1) {
return FlowKt__MigrationKt.onErrorReturn(flow, t, function1);
}
public static final <T> Flow<T> onStart(Flow<? extends T> flow, Function2<? super FlowCollector<? super T>, ? super Continuation<? super Unit>, ? extends Object> function2) {
return FlowKt__EmittersKt.onStart(flow, function2);
}
public static final <T> SharedFlow<T> onSubscription(SharedFlow<? extends T> sharedFlow, Function2<? super FlowCollector<? super T>, ? super Continuation<? super Unit>, ? extends Object> function2) {
return FlowKt__ShareKt.onSubscription(sharedFlow, function2);
}
public static final <T> ReceiveChannel<T> produceIn(Flow<? extends T> flow, CoroutineScope coroutineScope) {
return FlowKt__ChannelsKt.produceIn(flow, coroutineScope);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'publish()' is 'shareIn'. \npublish().connect() is the default strategy (no extra call is needed), \npublish().autoConnect() translates to 'started = SharingStared.Lazily' argument, \npublish().refCount() translates to 'started = SharingStared.WhileSubscribed()' argument.", replaceWith = @ReplaceWith(expression = "this.shareIn(scope, 0)", imports = {}))
public static final <T> Flow<T> publish(Flow<? extends T> flow) {
return FlowKt__MigrationKt.publish(flow);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'publish(bufferSize)' is 'buffer' followed by 'shareIn'. \npublish().connect() is the default strategy (no extra call is needed), \npublish().autoConnect() translates to 'started = SharingStared.Lazily' argument, \npublish().refCount() translates to 'started = SharingStared.WhileSubscribed()' argument.", replaceWith = @ReplaceWith(expression = "this.buffer(bufferSize).shareIn(scope, 0)", imports = {}))
public static final <T> Flow<T> publish(Flow<? extends T> flow, int i) {
return FlowKt__MigrationKt.publish(flow, i);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Collect flow in the desired context instead")
public static final <T> Flow<T> publishOn(Flow<? extends T> flow, CoroutineContext coroutineContext) {
return FlowKt__MigrationKt.publishOn(flow, coroutineContext);
}
public static final <T> Flow<T> receiveAsFlow(ReceiveChannel<? extends T> receiveChannel) {
return FlowKt__ChannelsKt.receiveAsFlow(receiveChannel);
}
public static final <S, T extends S> Object reduce(Flow<? extends T> flow, Function3<? super S, ? super T, ? super Continuation<? super S>, ? extends Object> function3, Continuation<? super S> continuation) {
return FlowKt__ReduceKt.reduce(flow, function3, continuation);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'replay()' is 'shareIn' with unlimited replay. \nreplay().connect() is the default strategy (no extra call is needed), \nreplay().autoConnect() translates to 'started = SharingStared.Lazily' argument, \nreplay().refCount() translates to 'started = SharingStared.WhileSubscribed()' argument.", replaceWith = @ReplaceWith(expression = "this.shareIn(scope, Int.MAX_VALUE)", imports = {}))
public static final <T> Flow<T> replay(Flow<? extends T> flow) {
return FlowKt__MigrationKt.replay(flow);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'replay(bufferSize)' is 'shareIn' with the specified replay parameter. \nreplay().connect() is the default strategy (no extra call is needed), \nreplay().autoConnect() translates to 'started = SharingStared.Lazily' argument, \nreplay().refCount() translates to 'started = SharingStared.WhileSubscribed()' argument.", replaceWith = @ReplaceWith(expression = "this.shareIn(scope, bufferSize)", imports = {}))
public static final <T> Flow<T> replay(Flow<? extends T> flow, int i) {
return FlowKt__MigrationKt.replay(flow, i);
}
public static final <T> Flow<T> retry(Flow<? extends T> flow, long j, Function2<? super Throwable, ? super Continuation<? super Boolean>, ? extends Object> function2) {
return FlowKt__ErrorsKt.retry(flow, j, function2);
}
public static final <T> Flow<T> retryWhen(Flow<? extends T> flow, Function4<? super FlowCollector<? super T>, ? super Throwable, ? super Long, ? super Continuation<? super Boolean>, ? extends Object> function4) {
return FlowKt__ErrorsKt.retryWhen(flow, function4);
}
public static final <T, R> Flow<R> runningFold(Flow<? extends T> flow, R r, Function3<? super R, ? super T, ? super Continuation<? super R>, ? extends Object> function3) {
return FlowKt__TransformKt.runningFold(flow, r, function3);
}
public static final <T> Flow<T> runningReduce(Flow<? extends T> flow, Function3<? super T, ? super T, ? super Continuation<? super T>, ? extends Object> function3) {
return FlowKt__TransformKt.runningReduce(flow, function3);
}
public static final <T> Flow<T> sample(Flow<? extends T> flow, long j) {
return FlowKt__DelayKt.sample(flow, j);
}
/* renamed from: sample-HG0u8IE reason: not valid java name */
public static final <T> Flow<T> m1820sampleHG0u8IE(Flow<? extends T> flow, long j) {
return FlowKt__DelayKt.m1822sampleHG0u8IE(flow, j);
}
public static final <T, R> Flow<R> scan(Flow<? extends T> flow, R r, Function3<? super R, ? super T, ? super Continuation<? super R>, ? extends Object> function3) {
return FlowKt__TransformKt.scan(flow, r, function3);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow has less verbose 'scan' shortcut", replaceWith = @ReplaceWith(expression = "scan(initial, operation)", imports = {}))
public static final <T, R> Flow<R> scanFold(Flow<? extends T> flow, R r, Function3<? super R, ? super T, ? super Continuation<? super R>, ? extends Object> function3) {
return FlowKt__MigrationKt.scanFold(flow, r, function3);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "'scanReduce' was renamed to 'runningReduce' to be consistent with Kotlin standard library", replaceWith = @ReplaceWith(expression = "runningReduce(operation)", imports = {}))
public static final <T> Flow<T> scanReduce(Flow<? extends T> flow, Function3<? super T, ? super T, ? super Continuation<? super T>, ? extends Object> function3) {
return FlowKt__MigrationKt.scanReduce(flow, function3);
}
public static final <T> SharedFlow<T> shareIn(Flow<? extends T> flow, CoroutineScope coroutineScope, SharingStarted sharingStarted, int i) {
return FlowKt__ShareKt.shareIn(flow, coroutineScope, sharingStarted, i);
}
public static final <T> Object single(Flow<? extends T> flow, Continuation<? super T> continuation) {
return FlowKt__ReduceKt.single(flow, continuation);
}
public static final <T> Object singleOrNull(Flow<? extends T> flow, Continuation<? super T> continuation) {
return FlowKt__ReduceKt.singleOrNull(flow, continuation);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'skip' is 'drop'", replaceWith = @ReplaceWith(expression = "drop(count)", imports = {}))
public static final <T> Flow<T> skip(Flow<? extends T> flow, int i) {
return FlowKt__MigrationKt.skip(flow, i);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'startWith' is 'onStart'. Use 'onStart { emit(value) }'", replaceWith = @ReplaceWith(expression = "onStart { emit(value) }", imports = {}))
public static final <T> Flow<T> startWith(Flow<? extends T> flow, T t) {
return FlowKt__MigrationKt.startWith(flow, t);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogue of 'startWith' is 'onStart'. Use 'onStart { emitAll(other) }'", replaceWith = @ReplaceWith(expression = "onStart { emitAll(other) }", imports = {}))
public static final <T> Flow<T> startWith(Flow<? extends T> flow, Flow<? extends T> flow2) {
return FlowKt__MigrationKt.startWith(flow, flow2);
}
public static final <T> Object stateIn(Flow<? extends T> flow, CoroutineScope coroutineScope, Continuation<? super StateFlow<? extends T>> continuation) {
return FlowKt__ShareKt.stateIn(flow, coroutineScope, continuation);
}
public static final <T> StateFlow<T> stateIn(Flow<? extends T> flow, CoroutineScope coroutineScope, SharingStarted sharingStarted, T t) {
return FlowKt__ShareKt.stateIn(flow, coroutineScope, sharingStarted, t);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Use 'launchIn' with 'onEach', 'onCompletion' and 'catch' instead")
public static final <T> void subscribe(Flow<? extends T> flow) {
FlowKt__MigrationKt.subscribe(flow);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Use 'launchIn' with 'onEach', 'onCompletion' and 'catch' instead")
public static final <T> void subscribe(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Unit>, ? extends Object> function2) {
FlowKt__MigrationKt.subscribe(flow, function2);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Use 'launchIn' with 'onEach', 'onCompletion' and 'catch' instead")
public static final <T> void subscribe(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Unit>, ? extends Object> function2, Function2<? super Throwable, ? super Continuation<? super Unit>, ? extends Object> function22) {
FlowKt__MigrationKt.subscribe(flow, function2, function22);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Use 'flowOn' instead")
public static final <T> Flow<T> subscribeOn(Flow<? extends T> flow, CoroutineContext coroutineContext) {
return FlowKt__MigrationKt.subscribeOn(flow, coroutineContext);
}
@Deprecated(level = DeprecationLevel.ERROR, message = "Flow analogues of 'switchMap' are 'transformLatest', 'flatMapLatest' and 'mapLatest'", replaceWith = @ReplaceWith(expression = "this.flatMapLatest(transform)", imports = {}))
public static final <T, R> Flow<R> switchMap(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Flow<? extends R>>, ? extends Object> function2) {
return FlowKt__MigrationKt.switchMap(flow, function2);
}
public static final <T> Flow<T> take(Flow<? extends T> flow, int i) {
return FlowKt__LimitKt.take(flow, i);
}
public static final <T> Flow<T> takeWhile(Flow<? extends T> flow, Function2<? super T, ? super Continuation<? super Boolean>, ? extends Object> function2) {
return FlowKt__LimitKt.takeWhile(flow, function2);
}
public static final <T, C extends Collection<? super T>> Object toCollection(Flow<? extends T> flow, C c, Continuation<? super C> continuation) {
return FlowKt__CollectionKt.toCollection(flow, c, continuation);
}
public static final <T> Object toList(Flow<? extends T> flow, List<T> list, Continuation<? super List<? extends T>> continuation) {
return FlowKt__CollectionKt.toList(flow, list, continuation);
}
public static final <T> Object toSet(Flow<? extends T> flow, Set<T> set, Continuation<? super Set<? extends T>> continuation) {
return FlowKt__CollectionKt.toSet(flow, set, continuation);
}
public static final <T, R> Flow<R> transform(Flow<? extends T> flow, Function3<? super FlowCollector<? super R>, ? super T, ? super Continuation<? super Unit>, ? extends Object> function3) {
return FlowKt__EmittersKt.transform(flow, function3);
}
public static final <T, R> Flow<R> transformLatest(Flow<? extends T> flow, Function3<? super FlowCollector<? super R>, ? super T, ? super Continuation<? super Unit>, ? extends Object> function3) {
return FlowKt__MergeKt.transformLatest(flow, function3);
}
public static final <T, R> Flow<R> transformWhile(Flow<? extends T> flow, Function3<? super FlowCollector<? super R>, ? super T, ? super Continuation<? super Boolean>, ? extends Object> function3) {
return FlowKt__LimitKt.transformWhile(flow, function3);
}
public static final <T, R> Flow<R> unsafeTransform(Flow<? extends T> flow, Function3<? super FlowCollector<? super R>, ? super T, ? super Continuation<? super Unit>, ? extends Object> function3) {
return FlowKt__EmittersKt.unsafeTransform(flow, function3);
}
public static final <T> Flow<IndexedValue<T>> withIndex(Flow<? extends T> flow) {
return FlowKt__TransformKt.withIndex(flow);
}
public static final <T1, T2, R> Flow<R> zip(Flow<? extends T1> flow, Flow<? extends T2> flow2, Function3<? super T1, ? super T2, ? super Continuation<? super R>, ? extends Object> function3) {
return FlowKt__ZipKt.zip(flow, flow2, function3);
}
}
Download file