akka.io
Class DelimiterFraming

java.lang.Object
  akka.io.PipelineStage<Context,Above,Below,Above,Below>
      akka.io.SymmetricPipelineStage<PipelineContext,ByteString,ByteString>
          akka.io.DelimiterFraming

public class DelimiterFraming
extends SymmetricPipelineStage<PipelineContext,ByteString,ByteString>

Pipeline stage for delimiter byte based framing and de-framing. Useful for string oriented protocol using '\n' or 0 as delimiter values.

Constructor Summary

DelimiterFraming(int maxSize, ByteString delimiter, boolean includeDelimiter)

Method Summary

java.lang.Object

apply(PipelineContext ctx)

Methods inherited from class akka.io.PipelineStage

combine, sequence

Methods inherited from class java.lang.Object

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

Constructor Detail

DelimiterFraming

public DelimiterFraming(int maxSize,
                        ByteString delimiter,
                        boolean includeDelimiter)

Method Detail

apply

public java.lang.Object apply(PipelineContext ctx)