akka-stream-circe

Json support for Akka Streams/Http via Jawn

License	Apache-2.0
Categories	Akka Container Microservices Reactive libraries
GroupId	de.knutwalker
ArtifactId	akka-stream-circe_2.11
Last Version	3.4.0
Release Date	Jul 12, 2017
Type	jar
Description	akka-stream-circe Json support for Akka Streams/Http via Jawn
Project URL	https://github.com/knutwalker/akka-stream-json/
Project Organization	de.knutwalker
Source Code Management	https://github.com/knutwalker/akka-stream-json/

Download akka-stream-circe_2.11

Filename	Size
akka-stream-circe_2.11-3.4.0.pom
akka-stream-circe_2.11-3.4.0.jar	8 KB
akka-stream-circe_2.11-3.4.0-sources.jar	2 KB
akka-stream-circe_2.11-3.4.0-javadoc.jar	349 KB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/de.knutwalker/akka-stream-circe_2.11/ -->
<dependency>
    <groupId>de.knutwalker</groupId>
    <artifactId>akka-stream-circe_2.11</artifactId>
    <version>3.4.0</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/de.knutwalker/akka-stream-circe_2.11/
implementation 'de.knutwalker:akka-stream-circe_2.11:3.4.0'

Gradle Kotlin

// https://jarcasting.com/artifacts/de.knutwalker/akka-stream-circe_2.11/
implementation ("de.knutwalker:akka-stream-circe_2.11:3.4.0")

Apache Buildr

'de.knutwalker:akka-stream-circe_2.11:jar:3.4.0'

Apache Ivy

<dependency org="de.knutwalker" name="akka-stream-circe_2.11" rev="3.4.0">
  <artifact name="akka-stream-circe_2.11" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='de.knutwalker', module='akka-stream-circe_2.11', version='3.4.0')
)

Scala SBT

libraryDependencies += "de.knutwalker" % "akka-stream-circe_2.11" % "3.4.0"

Leiningen

[de.knutwalker/akka-stream-circe_2.11 "3.4.0"]

Dependencies

compile (3)

Group / Artifact	Type	Version
org.scala-lang : scala-library	jar	2.11.8
de.knutwalker : akka-stream-json_2.11	jar	3.4.0
io.circe : circe-jawn_2.11	jar	0.8.0

provided (1)

Group / Artifact	Type	Version
com.typesafe.akka : akka-stream_2.11	jar	2.4.17

Project Modules

There are no modules declared in this project.

Akka Streams Json Support

This library provides Json support for stream based applications using jawn as a parser. It supports all backends that jawn supports with support for circe provided as a example.

Installation

There are two main modules, akka-stream-json and akka-http-json. akka-stream-json is the basis and provides the stream-based parser while akka-http-json enabled support to use the desired json library as an Unmarshaller.

libraryDependencies ++= List(
  "de.knutwalker" %% "akka-stream-json" % "3.3.0",
  "de.knutwalker" %% "akka-http-json" % "3.3.0"
)

akka-stream-json depends on jawn-parser at version 0.10.4 and is compiled against akka-stream at version 2.4.17. The circe submodule depends on version 0.8.0 of circe-jawn The Akk Http submodule depends on version 10.0.7 of akka-http

akka-stream-json is published for Scala 2.12 and 2.11.

Usage

The parser lives at de.knutwalker.akka.stream.JsonStreamParser

Use one of the constructor methods in the companion object to create the parser at various levels of abstraction, either a Stage, a Flow, or a Sink. You just add the jawn support facade of your choice and you will can parsed into their respective Json AST.

For Http support, either import de.knutwalker.akka.http.JsonSupport._ or mixin ... with de.knutwalker.akka.http.JsonSupport.

Given an implicit jawn facade, this enable you to decode into the respective Json AST using the Akka HTTP marshalling framework. As jawn is only about parsing and does not abstract over rendering, you'll only get an Unmarshaller.

Circe

libraryDependencies ++= List(
  "de.knutwalker" %% "akka-stream-circe" % "3.4.0",
  "de.knutwalker" %% "akka-http-circe" % "3.4.0"
)

(Using circe 0.8.0)

Adding support for a specific framework is quite easy.

These support modules allow you to directly marshall from/unmarshall into your data types using circes Decoder and Encoder type classes.

Just mixin or import de.knutwalker.akka.http.support.CirceHttpSupport for Http or pipe your Source[ByteString, _].via(de.knutwalker.akka.stream.CirceStreamSupport.decode[A]) to get a Source[A, _].

This flow even supports parsing multiple json documents in whatever fragmentation they may arrive, which is great for consuming stream/sse based APIs.

If there is an error in parsing the Json you can catch de.knutwalker.akka.http.support.CirceStreamSupport.JsonParsingException. The exception provides Circe cursor history, current cursor and the type hint of the error.

Why jawn?

Jawn provides a nice interface for asynchronous parsing. Most other Json marshalling provider will consume the complete entity at first, convert it to a string and then start to parse. With jawn, the json is incrementally parsed with each arriving data chunk, using directly the underlying ByteBuffers without conversion.

License

This code is open source software licensed under the Apache 2.0 License.

Versions

Version
3.4.0 Jul 12, 2017
3.3.0 Apr 17, 2017
3.2.0 Mar 14, 2017
3.1.0 Sep 2, 2016
3.0.0 Mar 26, 2016
2.0.0 Jan 21, 2016