by

Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • Apr 08 15:03

    mdedetrich on master

    Update Akka and remove 2.11 sup… (compare)

  • Apr 08 14:46

    mdedetrich on master

    Update Akka and remove 2.11 sup… (compare)

  • Apr 06 16:01

    mdedetrich on master

    Update to latest version of Cir… (compare)

  • Oct 09 2019 09:39
    mdedetrich closed #3
  • Oct 09 2019 09:39
    mdedetrich commented #3
  • Oct 09 2019 09:39
    mdedetrich closed #5
  • Oct 09 2019 09:39
    mdedetrich commented #5
  • Oct 09 2019 09:39
    mdedetrich commented #2
  • Oct 09 2019 04:19
    anskarl commented #6
  • Oct 08 2019 23:11
    mdedetrich commented #6
  • Oct 08 2019 20:12
    mdedetrich commented #6
  • Oct 08 2019 17:59

    mdedetrich on master

    Adds Scala 2.13 support - Up… Setting version to 0.4.0 - r… updates travis.yml - adds sc… and 1 more (compare)

  • Oct 08 2019 17:59
    mdedetrich closed #6
  • Oct 08 2019 10:14
    mdedetrich commented #6
  • Oct 07 2019 15:55
    anskarl commented #6
  • Oct 07 2019 15:55
    codecov[bot] commented #6
  • Oct 07 2019 15:54
    codecov[bot] commented #6
  • Oct 07 2019 15:53
    codecov[bot] commented #6
  • Oct 07 2019 15:49
    codecov[bot] commented #6
  • Oct 07 2019 15:49
    anskarl synchronize #6
Andrey Tararaksin
@atararaksin
Hi!
I'm looking into using akka-streams-json for the following case.
Consider a large json with the following structure: {"name": "test", "bars": [{...}, ...., {...}]}, and lets say it comes in as a Source[ByteString, _]. Since it's large, I would like to consume it in a streaming fashion.
Andrey Tararaksin
@atararaksin
The official example shows how I could transform it to a Source[Foo, _] (where Foo is a representation of a root object). But I need to process elements of the bars array, that is, to get Source[Bar, _]. Is it possible out-of-the box?
Matthew de Detrich
@mdedetrich
Let me have a look into this
I think this is more of an akka-streams question, but it sounds like you would just use .map on the stream and using the related Circe methods?