typelevel/fs2: Compositional, streaming I/O library for Scala

2146
STARS
98
WATCHERS
545
FORKS
76
ISSUES

fs2's Language Statistics

typelevel's Other Repos

Star history of fs2
Issue history of fs2

fs2 Recent Issues

Issue Title State Comments Created Date Updated Date Closed Date
Make `init:S` a by name parameter in `mapAccumulate`? open 0 2022-09-18 2022-09-19 -
Using the client to decode Server Sent Events misbehaves on both JVM and JS closed 1 2022-09-17 2022-09-19 2022-09-17
Provide StreamWithContext variant open 2 2022-09-08 2022-09-19 -
Akka Streams comparison and migration guide open 0 2022-09-07 2022-09-19 -
The instances allocated in the `Stream#flatmap` are referenced in the `Pull#BindBind` which can't be GCed before the whole Stream ends closed 5 2022-08-27 2022-09-19 2022-09-06
Stream.resource/Stream.bracket release action is not being completed when stream is interrupted closed 8 2022-08-14 2022-09-19 2022-08-15
Weird interaction between cancelation and interrruptWhen closed 2 2022-08-11 2022-09-19 2022-08-12
Time Series should use the `IO.monotonic` under the hood? closed 5 2022-08-06 2022-09-19 2022-08-09
Support glob patterns in fs2-io.js open 0 2022-07-17 2022-09-19 -
Possible binary compability problem on fs2-3.2.9 on Scala 2.12 closed 1 2022-07-08 2022-09-19 2022-07-08
Resource finalization out of order when using with concurrent stream. open 3 2022-06-29 2022-09-19 -
`raiseError` causes `writeOutputStream` to hang closed 5 2022-06-24 2022-09-19 2022-07-01
'.pauseWhen' does not respect pause signal if there is was no data available open 1 2022-06-20 2022-09-19 -
Type inference failing 3.2.8 open 3 2022-06-14 2022-09-19 -
Switch to `bigint` based Node.js APIs open 0 2022-06-06 2022-09-19 -
Memory leak when using WriterT open 2 2022-05-26 2022-09-19 -
Document for 2.x version? closed 1 2022-05-20 2022-09-19 2022-06-08
`Stream.fromBlockingIterator` is never interruptible closed 1 2022-05-17 2022-09-19 2022-07-01
Move `INothing` and `Pure` definitions to Cats closed 1 2022-04-03 2022-09-23 2022-04-05
Documentation: Add information about `Channel` open 0 2022-04-02 2022-08-30 -
Pull#mapOutput deleted between 2.5.10 and 3.0.0 open 1 2022-03-29 2022-09-28 -
Reimplement `Channel` in terms of `Queue` open 0 2022-03-19 2022-09-29 -
Counter-intuitive behavior with `interruptScope` and `IOLocal`s open 2 2022-03-09 2022-09-11 -
Exception escaping recover block using timed pull? open 0 2022-03-07 2022-09-10 -
Audit class tag comparisons in Chunk and fix unnecessary copying open 1 2022-03-02 2022-09-23 -
parEvalMapUnordered and friends can deadlock on exceptions in fs2 3.x, but not in fs2 2.x closed 10 2022-02-16 2022-09-12 2022-02-19
Accumulated `cats.data.WriterT` data not preserved from function passed to `fs2.io.readOutputStream` open 3 2022-02-10 2022-08-30 -
`Stream.groupWithin` swallowing errors when using `EitherT` effect. open 0 2022-01-31 2022-09-10 -
onFinalize kicks in before the stream in completed. closed 14 2022-01-03 2022-09-30 2022-01-13
`observe` could be simplified closed 4 2021-12-28 2022-08-19 2022-02-03
Replace the auto-generated Node.js facade with a hand-maintained facade closed 0 2021-12-27 2022-08-22 2022-06-08
Unix Socket SigInt fails resource cleanup open 1 2021-12-24 2022-09-19 -
Unexpected behaviors around the use of Pull (part II) closed 10 2021-12-21 2022-09-13 2021-12-23
`observe` stream may be cancelled for successful output streams closed 4 2021-12-17 2022-09-20 2021-12-24
StreamDecoder isn't well defined to work with bytes, bits and other repeatable codecs closed 2 2021-12-07 2022-09-21 2022-06-29
Intermittent test failure: fs2.ParEvalMapSuite.cancels unneeded closed 2 2021-12-05 2022-09-22 2021-12-06
Topic trait as a combination of TopicSource and TopicSink? open 0 2021-11-29 2022-09-13 -
mapAsyncUnordered sometimes hangs after exceptions closed 3 2021-11-28 2022-09-20 2021-12-09
Stream.fromQueue* "losing" elements closed 3 2021-11-26 2022-09-07 2021-11-29
Unexpected behaviors around the use of Pull closed 8 2021-11-22 2022-09-20 2021-12-06
concurrently hangs when eval cancelled closed 5 2021-11-17 2022-08-19 2021-11-19
par* hangs when receives IO.cancel as an effect to evaluate closed 4 2021-11-16 2022-09-25 2021-11-19
[fs2.io.net] `read` after a cancelled `read` causes `java.nio.channels.ReadPendingException` closed 18 2021-11-14 2022-09-11 2021-12-03
Ipv4Header codec works incorrect closed 0 2021-11-03 2022-09-26 2021-11-04
parjoin hangs when streams are terminated early closed 3 2021-11-03 2022-09-29 2021-11-03
Memory leak when combining 'metered' with 'observe' closed 6 2021-10-27 2022-09-26 2021-10-27
fs2 mapAsync behavior differs from akka streaming closed 2 2021-10-21 2022-09-13 2021-12-08
compactUntagged class cast exception closed 10 2021-10-13 2022-09-11 2021-10-14
Improve `parJoin` with the ability to select a join strategy open 4 2021-10-09 2022-09-30 -
decodeCWithCharset error handling inconsistency open 2 2021-10-07 2022-09-08 -