Package akka.stream.impl.io

Interface Summary

Interface	Description
ByteStringParser.ParseStep<T>
InputStreamSinkStage.AdapterToStageMessage
InputStreamSinkStage.StageWithCallback
InputStreamSinkStage.StreamToAdapterMessage
OutputStreamSourceStage.AdapterToStageMessage
TcpConnectionStage.TcpRole

Class Summary

Class	Description
ByteStringParser<T>	doParse() is the main driver for the parser.
ByteStringParser.ByteReader
ByteStringParser.FinishedParser$
ByteStringParser.ParseResult<T>	param: result - parser can return some element for downstream or return None if no element was generated in this step and parsing should immediately continue with the next step.
ByteStringParser.ParseResult$
ByteStringParser$	param: result - parser can return some element for downstream or return None if no element was generated in this step and parsing should immediately continue with the next step.
ConnectionSourceStage	INTERNAL API
ConnectionSourceStage$
FileOutputStage	INTERNAL API
FileSource	BLOCKING I/O READ
FileSource$	INTERNAL API
IncomingConnectionStage	INTERNAL API
InputStreamAdapter	INTERNAL API InputStreamAdapter that interacts with InputStreamSinkStage
InputStreamSinkStage	INTERNAL API
InputStreamSinkStage.Close$
InputStreamSinkStage.Data
InputStreamSinkStage.Data$
InputStreamSinkStage.Failed
InputStreamSinkStage.Failed$
InputStreamSinkStage.Finished$
InputStreamSinkStage.Initialized$
InputStreamSinkStage.ReadElementAcknowledgement$
InputStreamSinkStage$
InputStreamSource	INTERNAL API
OutgoingConnectionStage	INTERNAL API
OutgoingConnectionStage$
OutputStreamAdapter
OutputStreamGraphStage	INTERNAL API
OutputStreamSourceStage
OutputStreamSourceStage.Close$
OutputStreamSourceStage.Send
OutputStreamSourceStage.Send$
OutputStreamSourceStage$
TcpConnectionStage	Fail stage and report to localAddressPromise if still possible
TcpConnectionStage.Inbound
TcpConnectionStage.Inbound$
TcpConnectionStage.Outbound
TcpConnectionStage.Outbound$
TcpConnectionStage.TcpStreamLogic
TcpConnectionStage.WriteAck$
TcpConnectionStage$	Fail stage and report to localAddressPromise if still possible
TcpIdleTimeout	INTERNAL API
TcpIdleTimeout$	INTERNAL API
TLSActor	The SSLEngine needs bite-sized chunks of data but we get arbitrary ByteString from both the UserIn and the TransportIn ports.
TLSActor$	INTERNAL API.
TlsModule	INTERNAL API.
TlsModule$	INTERNAL API.
TlsUtils	INTERNAL API
TlsUtils$	INTERNAL API

Exception Summary

Exception	Description
ByteStringParser.ParsingException