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

# arrow

[Jose Antonio Jimenez]

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