Curious if the following workflow is supported: 1....

# mvikotlin

[doubov]

Curious if the following workflow is supported:
1. Setup a Flow<Model> (not a one-time action, but a stream that's dependent on some input)
2. Upon receiving new input, cancel the old Flow<Model> stream and restart it with the new input
If intents were a Flow<Intent>:

intents.filterIsInstance<Intent.A>.flatMapLatest { intent -> repo.fetchModels(intent.input).map { data -> Msg.SetData(data) } }

Upon receiving Intent.A we cancel the previously setup repo.fetchModels(...) stream and restart it with the new input.

As far as I can see, this isn't really doable with the current implementation, unless I've missed something. Thanks in advance! 🙏

[Arkadii Ivanov]

It looks like you want, on new Intent, cancel any previous async job and start a new one. A typical use case is filtering a list while the user types the query.

If this is what you need, then you can remember the Job returned by launch. On new Intent, cancel the previous Job if any, then launch and remember the new Job .

[doubov]

👍 yeah, that's the solution that I ended up with, just wanted to see if there's a more idiomatic one. Thanks!