Streaming with Monix's Observable

[vkostyukov]

Looks like we have all the pieces in place to make this happen.

[alexeygorobets]

hi! What's a preferred implementation to address the issue that a monix Observable has a kind F[_], but in Finch a stream needs to be S[_[_], _]?
Some class ObservableWrapper[F[_]: Effect, A](val observable: Observable[A]) to mimic it?

[vkostyukov]

@alexeygorobets How does Iterant relate to Observable? It seems to be in proper kind.

[alexeygorobets]

Sorry, somehow missing that we need Iterant.
Can you please explain then why this issue is called so?

[vkostyukov]

Oh the original plan I had in mind was to integrate with Observable, but, as you noted, it doesn't have the right kind. I was wondering if Iterant could serve as well as a replacement for Observable.

[alexeygorobets]

Thanks! I will take it then.