Hi guys is there any API in `Flow` like `Observable timeout` kotlinlang #coroutines

Channels

100daysofkotlin

100daysofkotlin-2021

algolialibraries

android-architecture

android-databinding

androidgithubprojects

androidx-xprocessing

arrow-contributors

beepiz-libraries

cincinnati-user-group

codemash-precompiler

codingconventions

competitive-programming

competitivecoding

compose-android

compose-desktop

compose-ui-showcase

connect-audit-events

cscenter-course-2016

domain-driven-design

effective-kotlin

effectivekotlin

embedded-kotlin

event21-community-content

fb-internal-demo

fluid-libraries

framework-elide

getting-started

github-workflows-kt

graviton-browser

image-processing

intellij-plugins

intellij-tricks

introduce-yourself

java-to-kotlin-refactoring

jhipster-kotlin

jvm-ir-backend-feedback

k2-early-adopters

kotest-contributors

kotlin-by-example

kotlin-data-storage

kotlin-foundation

kotlin-in-action

kotlin-multiplatform-contest

kotlin-pakistan

kotlinforbeginners

kotlingforbeginners

kotlinprogrammers

kotlintest-devs

kotlinultimatechallenge

kotlinx-datetime

lambdaworld_cadiz

language-evolution

language-proposals

leedskotlinusergroup

library-development

machinelearningbawas

myndocs-oauth2-server

navigation-architecture-component

ohio-kotlin-users

pattern-matching

pocketgitclient

practical-functional-programming

prozis-android-backup

python-contributors

realworldkotlin

refactoring-to-kotlin

refreshversions

russian-kotlinasfirst

skia-wasm-interop-temp

sofl-user-group

spring-security

squarelibraries

stayhungrystayfoolish

strife-discord-lib

swagger-gradle-codegen

swiss-user-group

tricity-kotlin-user-group

Title

s

sunbreak

08/30/2019, 11:37 AM

Hi, guys, is there any API in

Flow

like

Observable.timeout

?

m

Matej Drobnič

08/30/2019, 11:52 AM

I guess you could use

withTimeout

method of the coroutines?

g

gildor

08/30/2019, 12:10 PM

withTimeout is not the same, you cannot control emission of items, only overall collect yime. I would create a feature request for this if you have good use case

s

sunbreak

08/30/2019, 10:58 PM

I'm writing a MPP for Bluetooth communication. Some code like this

private fun receiveChunks(count: Int) = notepadType!!.receiveFileInput()
        .filter { it.first() == 0x05.toByte() }
        // TODO Take with timeout
        .take(count)

The 1.x version was writed in RxKotlin & RxSwift, quit the same way. It receives data in indexed and unsorted chunks, then reduces to a block, kind of TCP --> HTTP

g

gildor

08/31/2019, 3:16 AM

Yeah, make sense. I would create a feature request on kotlinx.coroutunes issue tracker. But in general it's not hard to write own operator for that with required semantics

s

sunbreak

08/31/2019, 4:53 AM

@gildor somehow, the

withTimeout

doesn't work on iOS without

runBlocking

. Is there another way round?

g

gildor

09/01/2019, 1:19 AM

Hard to say, maybe some bug, bit better reproduce it and report

But again, not sure what is required semantics for you, because withContext is not the same as Observable.timeout

s

sunbreak

09/01/2019, 2:19 AM

https://github.com/Kotlin/kotlinx.coroutines/issues/462#issuecomment-430111440

delay

requires

runBlocking

.

withTimeout

maybe the same

I tried implement the

Observabel.timeout

by

withTimeout

, but no luck. I find another way round, with

dispatch_after

on iOS and

Handler.postDelayed

on Android.

7 Views

#coroutines Join Slack