fromEither). Thanks for everyone’s help today!
when back pressured?
Although this terminology doesn't really apply to fs2 so I'm not sure exactly what you mean there
nminutes and return a Signal whose
getreturns always the latest values" is
@joesinghaus I get the feeling that the complex bits of
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
Stream.fixedDelay(5.minutes) zip Stream.repeatEval(apiCall)
apiCalllevel by returning an empty Stream (and potentially logging ofc)
ContextShift, I need to have a closer look at the PR
Ecbeing ok implicitly because there's the CPU one as a good default still applies here
Time[F]typeclass, the runtime gives you an implementation", e.g.