Package io.protostuff
Class Pipe
- java.lang.Object
-
- io.protostuff.Pipe
-
public abstract class Pipe extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Pipe.Schema<T>
-
Constructor Summary
Constructors Constructor Description Pipe()
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract Input
begin(Pipe.Schema<?> pipeSchema)
Begin preliminary input processing.protected abstract void
end(Pipe.Schema<?> pipeSchema, Input input, boolean cleanupOnly)
End input processing.protected Pipe
reset()
Resets this pipe for re-use.static <T> void
transferDirect(Pipe.Schema<T> pipeSchema, Pipe pipe, Input input, Output output)
This should not be called directly by applications.
-
-
-
Method Detail
-
reset
protected Pipe reset()
Resets this pipe for re-use.
-
begin
protected abstract Input begin(Pipe.Schema<?> pipeSchema) throws java.io.IOException
Begin preliminary input processing.- Throws:
java.io.IOException
-
end
protected abstract void end(Pipe.Schema<?> pipeSchema, Input input, boolean cleanupOnly) throws java.io.IOException
End input processing.If
cleanupOnly
is true, the io processing ended prematurely hence the underlying pipe should cleanup/close all resources that need to be.- Throws:
java.io.IOException
-
transferDirect
public static <T> void transferDirect(Pipe.Schema<T> pipeSchema, Pipe pipe, Input input, Output output) throws java.io.IOException
This should not be called directly by applications.- Throws:
java.io.IOException
-
-