Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

PipedStreamBuffer bug fix port #2459

Merged
merged 3 commits into from
Jul 3, 2021
Merged

PipedStreamBuffer bug fix port #2459

merged 3 commits into from
Jul 3, 2021

Conversation

vasilmkd
Copy link
Member

@vasilmkd vasilmkd commented Jul 2, 2021

Resolves #2457 for fs2 3.0.

Again, sorry for this whole mess.

Comment on lines +185 to +196
src
.through(text.utf8Decode)
.foldMonoid
.flatMap { expected =>
src
.through(test(chunkSize))
.through(text.utf8Decode)
.foldMonoid
.evalMap { actual =>
IO(assertEquals(actual, expected))
}
}
Copy link
Contributor

Choose a reason for hiding this comment

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

Suggested change
src
.through(text.utf8Decode)
.foldMonoid
.flatMap { expected =>
src
.through(test(chunkSize))
.through(text.utf8Decode)
.foldMonoid
.evalMap { actual =>
IO(assertEquals(actual, expected))
}
}
val actual = text.utf8Decode(test(chunkSize)(src)).foldMonoid
val expectedS = text.utf8Decode(src).foldMonoid
expectedS.flatMap { expected =>
actualS.evalMap { actual =>
IO(assertEquals(actual, expected))
}
}

Also, on a quick glance, can we compile both the expected and the actual stream?

@mpilquist
Copy link
Member

Feel free to adjust tests in subsequent PR. Going to merge this in preparation for a 3.0.6 release.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Regression in fs2 2.5.7 produces ArrayIndexOutOfBoundsException using writeOutputStream and readOutputStream
3 participants