Questions about fs2
Read more about fs2
python (65.1k questions)
javascript (44.2k questions)
reactjs (22.7k questions)
java (20.8k questions)
c# (17.4k questions)
html (16.3k questions)
r (13.7k questions)
android (12.9k questions)
parquet4s not returning all records
I have a simple Scala application that uses parquet4s with fs2 to read a set of partitioned records (spread across directories, generated by a Spark job).
When I run the app, it only returns a fractio...
samirbajaj
Votes: 0
Answers: 1
Dynamically add elements to fs2.Stream
How may I add new elements to fs2.Stream dynamically? For example, I would like to read key pressed as stream. I have tried to build the stream using Stream.eval with a function that use foreverM insi...
ayeo
Votes: 0
Answers: 1
Can I mock cats Clock to return time between 1:30pm to 1:45pm somehow in my unit tests?
I have a stream that just repeats every x seconds.
In my unit tests I want to test certain business logic, so I need my clock to start at 1:30pm and run until 1:45pm.
How can I mock this type of behav...
Blankman
Votes: 0
Answers: 1
Preventing Cats.IO to be executed in parallel
Forcing Cats.IO to be evaluated on a dedicated thread pool
How can I prevent the line.split to be executed on the Blocker[IO] execution context?
I hoped the IO effect will be evaluated on Two dedicate...
yonatan omer
Votes: 0
Answers: 0