Skip to content

Instantly share code, notes, and snippets.

@kartoffelsup
kartoffelsup / fxqueue.kt
Last active March 25, 2020 07:09
ArrowFw Queue
import arrow.Kind
import arrow.core.Either
import arrow.core.ListK
import arrow.core.extensions.list.traverse.sequence
import arrow.core.fix
import arrow.fx.ForIO
import arrow.fx.IO
import arrow.fx.Queue
import arrow.fx.extensions.fx
import arrow.fx.extensions.io.concurrent.concurrent