JarCasting
JarCasting JarCasting

akka-stream-json


License

License
Categories

Categories

JSON Data Akka Container Microservices Reactive libraries
GroupId

GroupId

org.mdedetrich
ArtifactId

ArtifactId

akka-stream-json_2.11
Last Version

Last Version

0.5.0
Release Date

Release Date
Type

Type

jar
Description

Description

akka-stream-json
akka-stream-json
Project URL

Project URL

https://github.com/mdedetrich/akka-streams-json
Project Organization

Project Organization

org.mdedetrich
Source Code Management

Source Code Management

https://github.com/mdedetrich/akka-streams-json

Download akka-stream-json_2.11

Filename Size
akka-stream-json_2.11-0.5.0.pom
akka-stream-json_2.11-0.5.0.jar 12 KB
akka-stream-json_2.11-0.5.0-sources.jar 2 KB
akka-stream-json_2.11-0.5.0-javadoc.jar 352 KB
Browse

How to add to project

<!-- https://jarcasting.com/artifacts/org.mdedetrich/akka-stream-json_2.11/ -->
<dependency>
    <groupId>org.mdedetrich</groupId>
    <artifactId>akka-stream-json_2.11</artifactId>
    <version>0.5.0</version>
</dependency>
// https://jarcasting.com/artifacts/org.mdedetrich/akka-stream-json_2.11/
implementation 'org.mdedetrich:akka-stream-json_2.11:0.5.0'
// https://jarcasting.com/artifacts/org.mdedetrich/akka-stream-json_2.11/
implementation ("org.mdedetrich:akka-stream-json_2.11:0.5.0")
'org.mdedetrich:akka-stream-json_2.11:jar:0.5.0'
<dependency org="org.mdedetrich" name="akka-stream-json_2.11" rev="0.5.0">
  <artifact name="akka-stream-json_2.11" type="jar" />
</dependency>
@Grapes(
@Grab(group='org.mdedetrich', module='akka-stream-json_2.11', version='0.5.0')
)
libraryDependencies += "org.mdedetrich" % "akka-stream-json_2.11" % "0.5.0"
[org.mdedetrich/akka-stream-json_2.11 "0.5.0"]

Dependencies

compile (3)

Group / Artifact Type Version
org.scala-lang : scala-library jar 2.11.12
com.typesafe.akka : akka-stream_2.11 jar 2.5.26
org.typelevel : jawn-parser_2.11 jar 0.14.2

Project Modules

There are no modules declared in this project.

Build Status Coverage Maven Join at Gitter Apache License

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.

Differences with akka-stream-json

This is a fork of akka-stream-json since it no longer appears to be maintained. Hence the main differences between akka-stream-json and this project is.

  • The project is called akka-streams-json rather than akka-stream-json. This is just to differentiate the git repos and project names.
  • This project aims to be updated to the latest versions of akka/akka-http/circe as frequent as possible. PR's are also welcome to maintain the project
  • We use ScalaTest rather then Specs2 for testing. This is because ScalaTest has better Future support compared to Specs2 (in order to do tests against Future in Specs2 you have to block on the Future which degrades performance a lot).

Apart from this, the actual initial code/implementation is exactly the same as the fork, the only difference being the package names (i.e. using org.mdedetrich rather than de.knutwalker). The following contents of README.md was also mainly copied from the original repo.

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(
  "org.mdedetrich" %% "akka-stream-json" % "0.6.0",
  "org.mdedetrich" %% "akka-http-json" % "0.6.0"
)

akka-streams-json depends on jawn-parser at version 1.0.0 for the 0.6.x series The circe submodule depends on version 0.13.x of circe-jawn for 0.6.x series

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

Usage

The parser lives at org.mdedetrich.akka.json.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 org.mdedetrich.akka.http.JsonSupport._ or mixin ... with org.mdedetrich.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(
  "org.mdedetrich" %% "akka-stream-circe" % "0.6.0",
  "org.mdedetrich" %% "akka-http-circe" % "0.6.0"
)

(Using circe 0.13.x)

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 org.mdedetrich.akka.http.support.CirceHttpSupport for Http or pipe your Source[ByteString, _].via(org.mdedetrich.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 org.mdedetrich.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
0.5.0
0.4.0
0.3.0
0.2.0
0.1.0