Channels
#coroutines
- d
Deactivated User
12/24/2016, 5:17 PMcool, at least now it fails fast and - d
Deactivated User
12/24/2016, 5:17 PMprovides something better than the failed cast - e
elizarov
12/24/2016, 5:18 PMYep. That is how it should be - e
elizarov
12/24/2016, 5:18 PMI don't know what I was thinking when I wrote original version. It was late at night 😉 - d
Deactivated User
12/24/2016, 5:18 PM🙂 - e
elizarov
12/24/2016, 5:19 PMYou might also consider using channels. - e
elizarov
12/24/2016, 5:19 PMChannels don't broadcast, though. - d
Deactivated User
12/24/2016, 5:19 PMI want to read it one by one - d
Deactivated User
12/24/2016, 5:19 PMand wait - e
elizarov
12/24/2016, 5:19 PMOnly one receiver gets a byte - e
elizarov
12/24/2016, 5:20 PMBut with channels it is Ok to kill one receiver and start next one - e
elizarov
12/24/2016, 5:23 PMThat would be Ok with
but withasyncGenerate
only one coroutine can read. WithasyncGenerate
various senders and receives can come and go and channels are buffered. So, sender suspends when buffers overflows, while receiver suspends when buffer is emptychannels - d
Deactivated User
12/24/2016, 5:23 PMit is a pair producer /consumer - d
Deactivated User
12/24/2016, 5:24 PMir just reads from once place - d
Deactivated User
12/24/2016, 5:24 PMat a time - d
Deactivated User
12/24/2016, 5:24 PMthere is just one consumer at a time - d
Deactivated User
12/24/2016, 5:24 PMper producer - d
Deactivated User
12/24/2016, 5:25 PMor it should be - d
Deactivated User
12/24/2016, 5:25 PMbecause I can only read once - d
Deactivated User
12/24/2016, 5:25 PMand I'm not trying to read two lines from the same stream - e
elizarov
12/24/2016, 5:25 PMThere's a good introduction to channels in Go (they have the whole language built around them), and here's the Kotlin implementation: https://github.com/Kotlin/kotlin-coroutines/blob/master/examples/channel/channel.kt - d
Deactivated User
12/24/2016, 5:26 PMgoing to try - e
elizarov
12/24/2016, 5:26 PMBut let's figure out what is going in your code first. Now it fails fast, but it is still not clear why. - d
Deactivated User
12/24/2016, 5:27 PMwell I think it is clear - d
Deactivated User
12/24/2016, 5:27 PMbecause I'm reading first from one coroutine - d
Deactivated User
12/24/2016, 5:28 PMthen that one is completed - d
Deactivated User
12/24/2016, 5:28 PMand trying to read from other coroutine - d
Deactivated User
12/24/2016, 5:28 PMwith the same iterator - d
Deactivated User
12/24/2016, 5:29 PMI ended with that approach because java nio doesn't allows me to cancel the read request - d
Deactivated User
12/24/2016, 5:29 PMso I needed always reading from one place