KAWACHI Takashi
KAWACHI Takashi
OK, I'll try to implement it as `foldResource` and `foldResourceAsync`.
Or is it too early to try to implement because the state is not in 1 - triaged? What should be discussed before implementation?
I wonder what type of a materialized value is good for these methods. Source.unfoldResource() has NotUsed as a materialized value. Should Sink.foldResource() have NotUsed too? Or is Future[Done] more suitable?...
I'm trying but stuck with an implementation. Please advise me if someone find what is wrong. This test fails because completeStage() is not called. https://github.com/akka/akka/compare/master...tkawachi:wip-sink-fold-resource?expand=1#diff-4f569ea1b7d25903a337710f5d18b4aaR138 I confirmed that onUpstreamFinish() is...
I found it caused by calling `pull(in)` for closed `in`. I'll continue...
I'd like to support it if we have an idea to access private/protected methods from a test code. Do you have an idea how the generated test code will be?
Recently this bug hasn't occurred in my local environment. I'll close it. Please reopen if anyone find this bug is still alive.
Unfortunately it still occurred with 0.3.1.
https://travis-ci.org/tkawachi/sbt-doctest/jobs/95558125#L1241