I'd like to store action and to run when i can run form first and last. I ' m using a channel but i...

# coroutines

[Gioele Dev]

I'd like to store action and to run when i can run form first and last. I ' m using a channel but it doesn't.

[Gioele Dev]

var channelScope = CoroutineScope(<http://Dispatchers.IO|Dispatchers.IO> + Job())
 val channel : Channel<TLocalEntityInterface> = Channel<TLocalEntityInterface>()

override suspend fun send( elem: TLocalEntityInterface) {
     channelScope.launch {
         channel.send(elem)
     }
 }


 override suspend  fun startChannel( ) {
         for (element in channel) {
             var entity = channel.receive()
             logRepository.tag("sync").d("sync: startChannel  stampo un elmentot ${entity}".toUpperCase())

             when(entity){
                 is MyType -> {
                    Timber.tag("sync").d(": nome  ${entity.name}")
                 }
             }
         }

 }

[Gioele Dev]

iit doesn/t work

[Pablichjenkov]

From what coroutine you call startChannel?

[Gioele Dev]

i used channelScope but it didn.t work

[Pablichjenkov]

You can try channel.consumeEach

[Gioele Dev]

i need to store data and after a trigger flag comsume data

[Pablichjenkov]

And what is failing specifically? The channel.receive() never returns?

[Gioele Dev]

a monent i try again