Package io.gravitee.gateway.api.stream

Class TransformableStream

java.lang.Object

io.gravitee.gateway.api.stream.SimpleReadWriteStream<Buffer>

io.gravitee.gateway.api.stream.BufferedReadWriteStream

io.gravitee.gateway.api.stream.TransformableStream

All Implemented Interfaces:

ReadStream<Buffer>, ReadWriteStream<Buffer>, WriteStream<Buffer>

Direct Known Subclasses:

TransformableRequestStream, TransformableResponseStream

public abstract class TransformableStream
extends BufferedReadWriteStream

Author:

David BRASSELY (david.brassely at graviteesource.com), GraviteeSource Team

Field Summary

Fields

Modifier and Type	Field	Description
protected final Buffer	buffer
protected String	contentType
protected io.gravitee.policy.api.PolicyChain	policyChain
protected Function<Buffer,Buffer>	transform

Fields inherited from class io.gravitee.gateway.api.stream.SimpleReadWriteStream

bodyHandler, endHandler

Constructor Summary

Constructors

Constructor	Description
TransformableStream()
TransformableStream(int length)

Method Summary

Modifier and Type	Method	Description
String	contentType()
void	end()
protected TransformableStream	flush(Buffer chunk)
io.gravitee.policy.api.PolicyChain	policyChain()
Function<Buffer,Buffer>	transform()
TransformableStream	write(Buffer chunk)

Methods inherited from class io.gravitee.gateway.api.stream.SimpleReadWriteStream

bodyHandler, endHandler

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.gravitee.gateway.api.stream.ReadStream

pause, resume

Methods inherited from interface io.gravitee.gateway.api.stream.WriteStream

drainHandler, end, writeQueueFull

Field Details

buffer

protected final Buffer buffer

contentType

protected String contentType

policyChain

protected io.gravitee.policy.api.PolicyChain policyChain

transform

protected Function<Buffer,Buffer> transform

Constructor Details

TransformableStream

public TransformableStream(int length)

TransformableStream

public TransformableStream()

Method Details

write

public TransformableStream write(Buffer chunk)

Specified by:

write in interface WriteStream<Buffer>

Overrides:

write in class SimpleReadWriteStream<Buffer>

flush

protected TransformableStream flush(Buffer chunk)

end

public void end()

Specified by:

end in interface WriteStream<Buffer>

Overrides:

end in class SimpleReadWriteStream<Buffer>

contentType

public String contentType()

transform

public Function<Buffer,Buffer> transform()

policyChain

public io.gravitee.policy.api.PolicyChain policyChain()