``` fun &lt;A&gt; <http://arrow.effects.IO|arrow.e...

# arrow

[pakoito]

fun <A> <http://arrow.effects.IO|arrow.effects.IO><A>.toSource(): akka.stream.javadsl.AsyncSource<A, akka.NotUsed> { emitter ->
    return this.unsafeRunAsync { it.fold(emitter::onError, emitter::onNext)}
}