Hello all, is there any way to stop pipeline-blocking process?

close the input

but I use (to-chan <collection>), how to close this?

it is already closed, so pipeline-blocking will stop once it empties the channel

but, if I want to force stop ?

you cannot

😮

so, I have to change the way to process it?

yes

all the ways to stop a thread from doing things non-cooperatively are deprecated on the jvm

so if you want to be able to stop some computation in the middle, you need to write it in such a way as to check in the middle to see if needs to stop

I think you can close the channel returned from (to-chan coll) to end the process prematurely.

@jkr.sw I'll try to use It in atom and close It externally