[error] /Users/bholt/Developer/github/fs2/core/shared/src/test/scala/fs2/TestUtil.scala:109:48: ambiguous implicit values: [error] both method catsStdInstancesForEither in trait EitherInstances of type [A]=> cats.MonadError[[β$0$]scala.util.Either[A,β$0$],A] with cats.Traverse[[β$1$]scala.util.Either[A,β$1$]] [error] and method catsStdInstancesForFuture in trait FutureInstances of type (implicit ec: scala.concurrent.ExecutionContext)cats.MonadError[scala.concurrent.Future,Throwable] with cats.CoflatMap[scala.concurrent.Future] with cats.Monad[scala.concurrent.Future] [error] match expected type cats.ApplicativeError[F,Throwable] [error] Failure("pure-failure", Stream.raiseError(new Err)), [error] ^
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)