public class ToStrict extends org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,HttpEntity.Strict>>
Constructor and Description |
---|
ToStrict(scala.concurrent.duration.FiniteDuration timeout,
scala.Option<java.lang.Object> maxBytes,
ContentType contentType) |
Modifier and Type | Method and Description |
---|---|
org.apache.pekko.stream.Inlet<org.apache.pekko.util.ByteString> |
byteStringIn() |
org.apache.pekko.stream.stage.GraphStageLogic |
createLogic(org.apache.pekko.stream.Attributes inheritedAttributes) |
org.apache.pekko.stream.Outlet<HttpEntity.Strict> |
httpEntityOut() |
org.apache.pekko.stream.Attributes |
initialAttributes() |
org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,HttpEntity.Strict> |
shape() |
java.lang.String |
toString() |
createLogicAndMaterializedValue
addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, named, traversalBuilder, withAttributes
public ToStrict(scala.concurrent.duration.FiniteDuration timeout, scala.Option<java.lang.Object> maxBytes, ContentType contentType)
public org.apache.pekko.stream.Inlet<org.apache.pekko.util.ByteString> byteStringIn()
public org.apache.pekko.stream.stage.GraphStageLogic createLogic(org.apache.pekko.stream.Attributes inheritedAttributes)
createLogic
in class org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,HttpEntity.Strict>>
public org.apache.pekko.stream.Outlet<HttpEntity.Strict> httpEntityOut()
public org.apache.pekko.stream.Attributes initialAttributes()
initialAttributes
in class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,HttpEntity.Strict>,org.apache.pekko.NotUsed>
public org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,HttpEntity.Strict> shape()
public java.lang.String toString()
toString
in class java.lang.Object