Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • Jul 14 20:24
    coveralls commented #20
  • Jul 14 20:24
    coveralls commented #20
  • Jul 14 17:52

    mdedetrich on add-publishLocal-to-skip

    (compare)

  • Jul 14 17:52

    mdedetrich on master

    Add skip to publishLocal for no… (compare)

  • Jul 14 17:52
    mdedetrich closed #20
  • Jul 14 17:49
    mdedetrich opened #20
  • Jul 14 17:49

    mdedetrich on add-publishLocal-to-skip

    Add skip to publishLocal for no… (compare)

  • Jul 14 15:15
    coveralls commented #19
  • Jul 14 15:15
    coveralls commented #19
  • Jul 14 15:03

    mdedetrich on master

    Setting version to 0.8.0 Setting version to 0.8.1-SNAPSH… (compare)

  • Jul 14 14:46

    mdedetrich on update-version-in-README

    (compare)

  • Jul 14 14:46

    mdedetrich on master

    Update version in README.md (compare)

  • Jul 14 14:46
    mdedetrich closed #19
  • Jul 14 14:45

    mdedetrich on reoder-release-step

    (compare)

  • Jul 14 14:44
    mdedetrich opened #19
  • Jul 14 14:43

    mdedetrich on update-version-in-README

    Update version in README.md (compare)

  • Jul 14 12:13

    mdedetrich on master

    Reorder release step (compare)

  • Jul 14 11:43

    mdedetrich on master

    Reorder release step (compare)

  • Jul 14 11:43
    mdedetrich closed #18
  • Jul 14 11:42
    coveralls commented #18
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?