Most discussion is on Typelevel Discord: https://discord.gg/bSQBZA3Ced
@joesinghaus I get the feeling that the complex bits of utf8Decode (continuationBytes, processSingleChunk, lastIncompleteBytes) are there to deal with the complexities of utf8.
I don't have a specific encoding in mind, I want this to be generic, so writing my own isn't really an option if I have to do something similar for every possible encoding?
The generic part doPull doesn't seem too complex, have you thought how to be generic over possible format? that will require different logic since encodings are different
the only gotcha
assuming your Stream is
Stream.fixedDelay(5.minutes) zip Stream.repeatEval(apiCall)
make sure you handle the error at the
apiCall level by returning an empty Stream (and potentially logging ofc)
unless you want one api call failure to end the whole thing
anyway, the types are different
ah, sorry
your
Segment is of Unit
then they are effectively the same
https://functional-streams-for-scala.github.io/fs2/guide.html uses Segment -- what should be used instead?
we are using Chunk only now
but you can't really do that unless you upgrade to 1.0-M3
because Chunk in 0.10 is purposefully underpowered
my inclination is no for
Timer
as for
ContextShift, I need to have a closer look at the PR
right
I think the argument Daniel made about
Ec being ok implicitly because there's the CPU one as a good default still applies here
my mental model for Timer is still "there's a
Time[F] typeclass, the runtime gives you an implementation", e.g. IOApp
but I'm open to chaining my mind and more importantly I'm exhausted by having to think about it :joy: :joy:
oh ContextShift is okay to pass implicitly
trait ContextShift[F[_]] {
def shift: F[Unit]
def evalOn[A](ec: ExecutionContext)(fa: F[A]): F[A]
}
it's defo a typeclass then in my mind
Thanks Pavel ;)
it's the return type
you can imagine it as a computation the emits some values and emits returns a new thing
it's actually similar to pagination ;)
which is indeed pull-based
note that to convert a
Pull to a Stream
R needs to Unit