My problem is it gets closed to early before this implementa

Question

My problem is it gets closed to early before this implementation we tried with `any` but the channel was closed before the `offer` in the callback being wrapped

elizarov · Answer

Because you did not suspend the`produce` See my answer above You should wait for cancellation inside produce after the callback is set

elizarov · Answer

define ``` suspend fun awaitCancel Nothing = suspendCancellableCoroutine ```

dave08 · Answer

Oh thanks

elizarov · Answer

dave08 · Answer

Now we did this ```suspend fun awaitCancel Nothing = suspendCancellableCoroutine suspend fun registerBroadcastReceiver context Context intentFilter IntentFilter ReceiveChannel lt Intent gt = produce lt Intent gt capacity = Channel UNLIMITED var broadcastReceiver BroadcastReceiver = null try broadcastReceiver = object BroadcastReceiver override fun onReceive context Context intent Intent offer intent also context registerReceiver it intentFilter awaitCancel catch e CancellationException context unregisterReceiver broadcastReceiver ``` But it s still not suspending it just continues on with the code

deviant · Answer

i use `delay Long MAX LONG ` for such cases probably not the best solution though slightly smiling face

elizarov · Answer

Maybe `delay Long MAX LONG ` overflows or something like that and does not wait

deviant · Answer

hmm what do you mean by overflows

elizarov · Answer

There was a bug with that some time in the past Should have been fixed but who knows

elizarov · Answer

Test `delay Long MAX LONG ` separately and if it does not wait report a separate issue about it please

deviant · Answer

oh android i remember that brilliant fix with ` 2` slightly smiling face

elizarov · Answer

Overflows as in the following code ``` val deadline = curTime + timeout MAX LONG so deadline is negative whiile curTime lt deadline wait aha ```

deviant · Answer

now it works as expected

dave08 · Answer

I think it s not waiting with `awaitCancel` when we did it with delay it worked

elizarov · Answer

That is strange `suspendCancellableCoroutine ` should wait properly No chance for it to wakeup but on cancellation

elizarov · Answer

no one is there to resume since we are not even storing its continuation anywhere

dave08 · Answer

Here s the current code ```suspend fun registerBroadcastReceiver context Context intentFilter IntentFilter ReceiveChannel lt Intent gt = produce lt Intent gt capacity = Channel UNLIMITED var broadcastReceiver BroadcastReceiver = null try broadcastReceiver = object BroadcastReceiver override fun onReceive context Context intent Intent offer intent also context registerReceiver it intentFilter awaitCancel finally context unregisterReceiver broadcastReceiver ```

dave08 · Answer

Maybe we re doing something wrong

elizarov · Answer

Maybe Can you reproduce this problem in some self contained example

dave08 · Answer

This just hangs < elizarov>

dave08 · Answer

Now I corrected it I hope but the first test still hangs

elizarov · Answer

I m looking at at

elizarov · Answer

In your first test you you first suspend in `channel any` then you try to send hello there

elizarov · Answer

You should test it like this ``` val result = async channel any if it action == hello channel cancel true else false context send hello assert result await ```

dave08 · Answer

That seems to work thanks

dave08 · Answer

What s funny is that the test still isn t recreating the exact situation in the app it s still not suspending there I guess I ll try working on it in the next few days if I notice any edge cases I ll report them back then thanks anyways