com.artipie.http.stream

Class ByteByByteSplit

java.lang.Object

com.artipie.http.stream.ByteByByteSplit

All Implemented Interfaces:

org.reactivestreams.Processor<ByteBuffer,org.reactivestreams.Publisher<ByteBuffer>>, org.reactivestreams.Publisher<org.reactivestreams.Publisher<ByteBuffer>>, org.reactivestreams.Subscriber<ByteBuffer>

public final class ByteByByteSplit
extends Object
implements org.reactivestreams.Processor<ByteBuffer,org.reactivestreams.Publisher<ByteBuffer>>

Byte stream split implementation based on Circular buffer of bytes.

Since:

0.4

Constructor Summary

Constructors

Constructor and Description
ByteByByteSplit(byte[] delim) Ctor.

Method Summary

Modifier and Type	Method and Description
void	onComplete()
void	onError(Throwable throwable)
void	onNext(ByteBuffer next)
void	onSubscribe(org.reactivestreams.Subscription sub)
void	subscribe(org.reactivestreams.Subscriber<? super org.reactivestreams.Publisher<ByteBuffer>> sub)

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteByByteSplit

public ByteByByteSplit(byte[] delim)

Ctor.

Parameters:

delim - The delimiter.

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super org.reactivestreams.Publisher<ByteBuffer>> sub)

Specified by:

subscribe in interface org.reactivestreams.Publisher<org.reactivestreams.Publisher<ByteBuffer>>

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription sub)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<ByteBuffer>

onNext

public void onNext(ByteBuffer next)

Specified by:

onNext in interface org.reactivestreams.Subscriber<ByteBuffer>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface org.reactivestreams.Subscriber<ByteBuffer>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<ByteBuffer>