Package io.protostuff
Class Pipe
java.lang.Object
io.protostuff.Pipe
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic class
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected 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.
-
Field Details
-
input
-
output
-
-
Constructor Details
-
Pipe
public Pipe()
-
-
Method Details
-
reset
Resets this pipe for re-use. -
begin
Begin preliminary input processing.- Throws:
IOException
-
end
protected abstract void end(Pipe.Schema<?> pipeSchema, Input input, boolean cleanupOnly) throws 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:
IOException
-
transferDirect
public static <T> void transferDirect(Pipe.Schema<T> pipeSchema, Pipe pipe, Input input, Output output) throws IOException This should not be called directly by applications.- Throws:
IOException
-