com.asakusafw.utils.io

Class DefaultSerialization.ObjectSink<T>

java.lang.Object

com.asakusafw.utils.io.DefaultSerialization.ObjectSink<T>

Type Parameters:

T - the object type

All Implemented Interfaces:

Sink<T>, Closeable, Flushable, AutoCloseable

Enclosing class:

DefaultSerialization<T>

public static final class DefaultSerialization.ObjectSink<T>
extends Object
implements Sink<T>

An ObjectOutput adapter implementation of Sink.

Constructor Summary

Constructors

Constructor and Description
ObjectSink(ObjectOutput output) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	close()
void	flush()
void	put(T object) Puts an object to this sink.

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectSink

public ObjectSink(ObjectOutput output)

Creates a new instance.

Parameters:

output - the target ObjectOutput.

Method Detail

put

public void put(T object)
         throws IOException,
                InterruptedException

Description copied from interface: Sink

Puts an object to this sink.

Specified by:

put in interface Sink<T>

Parameters:

object - the target object

Throws:

IOException - if failed to put the object by I/O error

InterruptedException - if interrupted while putting the object

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException