Skip to content

Added akka stream decoding flow and sink #18

Merged
merged 3 commits into from
Apr 15, 2020
Merged

Added akka stream decoding flow and sink #18

merged 3 commits into from
Apr 15, 2020

Conversation

vitaliihonta
Copy link

No description provided.

monadError: MonadError[G, Throwable]): G[A] = {
val sr: XmlStreamReader = XmlDecoder.createStreamReader(charset)
val cursor = new Cursor(sr)
implicit def DecoderOps[A](xmlDecoder: XmlDecoder[A]): DecoderOps[A] = new DecoderOps[A](xmlDecoder)
Copy link
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Как насчёт сделать такой же трюк для мониска заодно?

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

А для чего этот трюк?

monadError: MonadError[G, Throwable]): G[A] = {
val sr: XmlStreamReader = XmlDecoder.createStreamReader(charset)
val cursor = new Cursor(sr)
implicit def DecoderOps[A](xmlDecoder: XmlDecoder[A]): DecoderOps[A] = new DecoderOps[A](xmlDecoder)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

А для чего этот трюк?

@valentiay valentiay merged commit 5e1d2f1 into Tinkoff:master Apr 15, 2020
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants