Package com.here.platform.data.client.json

Class StreamingJsonParser<J>

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<S,org.apache.pekko.NotUsed>

org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,scala.Tuple2<scala.Option<String>,J>>>

com.here.platform.data.client.json.StreamingJsonParser<J>

All Implemented Interfaces:

org.apache.pekko.stream.Graph<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,scala.Tuple2<scala.Option<String>,J>>,org.apache.pekko.NotUsed>

public final class StreamingJsonParser<J>
extends org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,scala.Tuple2<scala.Option<String>,J>>>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph

org.apache.pekko.stream.Graph.GraphMapMatVal<S extends org.apache.pekko.stream.Shape,M extends Object>

Constructor Summary

Constructors

Constructor	Description
StreamingJsonParser(scala.Option<String> description, PimpedAsyncParser<J> parser, Facade<J> facade)

Method Summary

Modifier and Type	Method	Description
static <J> org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,scala.Tuple2<scala.Option<String>,J>>>	apply(scala.Option<String> description, Facade<J> evidence$1)
org.apache.pekko.stream.stage.GraphStageLogic	createLogic(org.apache.pekko.stream.Attributes inheritedAttributes)
static <J> org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,scala.Tuple2<scala.Option<String>,J>,org.apache.pekko.NotUsed>	flow(scala.Option<String> description, Facade<J> evidence$2)
org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,scala.Tuple2<scala.Option<String>,J>>	shape()

Methods inherited from class org.apache.pekko.stream.stage.GraphStage

createLogicAndMaterializedValue

Methods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue

addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, initialAttributes, named, traversalBuilder, withAttributes

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

StreamingJsonParser

public StreamingJsonParser(scala.Option<String> description,
 PimpedAsyncParser<J> parser,
 Facade<J> facade)

Method Details

apply

public static <J>
org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,scala.Tuple2<scala.Option<String>,J>>> apply(scala.Option<String> description,
 Facade<J> evidence$1)

flow

public static <J>
org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,scala.Tuple2<scala.Option<String>,J>,org.apache.pekko.NotUsed> flow(scala.Option<String> description,
 Facade<J> evidence$2)

shape

public org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,scala.Tuple2<scala.Option<String>,J>> shape()

createLogic

public org.apache.pekko.stream.stage.GraphStageLogic createLogic(org.apache.pekko.stream.Attributes inheritedAttributes)

Specified by:

createLogic in class org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,scala.Tuple2<scala.Option<String>,J>>>