because the actual implementation of
take is in terms of uncons
hey @SystemFw , we're running a service reading from Google PubSub, and we occassionaly this beautiful stack trace: https://gist.github.com/CremboC/6f3f158bd32720890e47519211a1a71d (sorry it's in one line, but you'll see a pattern quickly!). any ideas?
this was fixed in 0.10.3
I assume they're backwards compatible?
I've been trying to write a function that streams until it has seen N objects equal to a provided instance of O. The last piece of the puzzle is how to emit the stream. I think I need to pull output but somehow need to join that to the tail of the stream in the recursive call? https://gist.github.com/justinhj/10fd8dc2a364a1fdbade36352b15abe0
maintaining a list, but with
Pipe[F,O,O] as type seems incompatible
Pull.output1 might be what you want to use
typically you compose Pulls with
>>
how about
s.pull.uncons1.flatMap {
case Some((o, tl)) =>
if(o == thing) {
output1(o) >> go(tl, n - 1)
}
else {
output1(o) >> go(tl,n)
}
case None =>
Pull.done
does that seem like what you are after @justinhj
since
eval returns it in R not O
another problem is that you are accumulating a List[O] as your output
actually that's the confusion
you are used to the typical accumulator based thing, where you first accumulate the whole result and then you "return it"
but here you want to do this in a streaming fashion, so as soon as you find something that needs to be emitted, you just emit it
and
Pull.output/output1 is the command that lets you do so
in that case it would never emit!
When I started out I wish I'd ask what @SystemFw is offering @justinhj
so you should say yes!
it was a huge missing piece for me in my internal model of how fs2 worked
I was going on to add a little interlude on how to view effects as languages, but I can skip that if you want
and only focus on
Pull
wdyt?
jmcardon @jmcardon gathers for grand wizard Fabio's mini-talk
the purple text thingy
PeterAaser @PeterAaser attempts to read documentation