Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • Jan 31 04:19
    404- forked
    404-/fs2
  • Jan 31 03:01
    SethTisue commented #1232
  • Jan 30 17:22
  • Jan 30 13:45
  • Jan 30 10:48
    pchlupacek commented #1406
  • Jan 30 10:47
    pchlupacek commented #1406
  • Jan 30 10:39
    pchlupacek commented #1407
  • Jan 30 09:58
    lJoublanc commented #870
  • Jan 30 09:42
    vladimir-popov commented #1407
  • Jan 30 08:10
    vladimir-popov closed #1407
  • Jan 30 08:10
    vladimir-popov commented #1407
  • Jan 29 19:20
    SystemFw commented #1407
  • Jan 29 19:20
    SystemFw commented #1407
  • Jan 29 18:57
    SystemFw commented #1406
  • Jan 29 17:47
    pchlupacek commented #1406
  • Jan 29 17:42
    pchlupacek commented #1406
  • Jan 29 17:39
    pchlupacek commented #1407
  • Jan 29 17:39
    vladimir-popov edited #1407
  • Jan 29 17:38
    vladimir-popov commented #1406
  • Jan 29 17:37
    pchlupacek commented #1406
Mark Tomko
@mtomko
Not terribly long ago. My bet is my Pull was not well done.
Fabio Labella
@SystemFw
anyway, we can possibly help either figuring that out, or writing a lower level version
for the grouping, you could try segmentN(4) after lines, instead of a custom pull
Mark Tomko
@mtomko
That looks promising
I'll rework it with segmentN and post again if it's still slow.
I need to turn in, I really appreciate all the help and patience.
Thanks everyone!
Fabio Labella
@SystemFw
:) :wave:
Alex Henning Johannessen
@ahjohannessen
@SystemFw On your slides wrt. fs2 + declarative control flow you use Stream.sleep in some examples. I cannot find sleep on Stream, just on Scheduler.
Fabio Labella
@SystemFw
Yeah, it's not released yet
Use Scheduler or Timer
Scheduler sleep gives you a stream, Timer sleep gives you an F that you'll need to eval
Alex Henning Johannessen
@ahjohannessen
Aah :) which release is that?
Fabio Labella
@SystemFw
Well, which one are you asking about?
But basically in 0.10.3 we have added the latest cats effect, with enhanced concurrency features
But we're not taking advantage of them yet
There's a branch, however
So in this case Scheduler will be removed since we have Timer in cats effect, and sleep will go on Stream
We are still deciding when and how to release that (new milestone? 0.11?)
Alex Henning Johannessen
@ahjohannessen
Ah great, yeah I meant branch :)
Michael Pilquist
@mpilquist
I'm still hoping for fs2 1.0 in mid-May once cats-effect 1.0 is out
Peter Aaser
@PeterAaser
today my brakes failed mid traffic
I wish hyundai would use fs2
maybe then their cars wouldn't suffer random brake failures
Gavin Bisesi
@Daenyth
Can someone explain segments vs chunks?
and how that all interacts?
Fabio Labella
@SystemFw
@Daenyth yeah, I can do it in a bit
Gavin Bisesi
@Daenyth
thanks!
Specifically I ask because I have a Stream[IO, ByteString] where ByteString is an akka rope structure like ByteVector, and I want to get to bytes so I can use text stuff with it
and I have
byteStream
      .mapChunks(c => c.map(bs => bs.toVector).toSegment)
      .flatMap(Stream.emits(_).covary[IO])
but it feels wrong
Fabio Labella
@SystemFw
why does it feel wrong?
Christopher Davenport
@ChristopherDavenport
tldr: chunk - index based access
Gavin Bisesi
@Daenyth
@SystemFw it feels like I should be able to do this in a single step
Fabio Labella
@SystemFw
wdym exactly by "this" and "a single step" sorry
Gavin Bisesi
@Daenyth
the operation above
mapChunks+flatMap(Stream.emits)
also I don't understand when I want to work with chunks vs want to work with segments
Fabio Labella
@SystemFw
ok
Edmund Noble
@edmundnoble
@mpilquist I'm doing that. I don't even use fs2-scalaz though.
Gavin Bisesi
@Daenyth
or what the relation between chunk and segment is at all
Fabio Labella
@SystemFw
I can give some context
Edmund Noble
@edmundnoble
Didn't know that was still a thing.
Fabio Labella
@SystemFw
the tl;dr is that you want to work with Segment as much as possible
so, what is this all about
basically in older versions of fs2 there was no concept of chunking (let alone segments) at all
a Stream logically works in terms of single elements, right?
Gavin Bisesi
@Daenyth
right
Fabio Labella
@SystemFw
you produce element, you transform elements, you consume elements
Gavin Bisesi
@Daenyth
I have some concept of the chunking/batching thing - you keep groups of elements close in time together in order to get locality and better performance in general, right?