hu.akarnokd.reactive4java.util

Class SequentialCloseable

java.lang.Object

hu.akarnokd.reactive4java.util.SequentialCloseable

All Implemented Interfaces:

Cancelable, java.io.Closeable, java.lang.AutoCloseable

public class SequentialCloseable
extends java.lang.Object
implements java.io.Closeable, Cancelable

A closeable container which closes the previously managed closeable if a new closeable is assigned to it.

Closeables assigned to this container after it was closed is ignored and the incoming closeable is closed instantly.

The implementation is thread-safe.

Since:

0.97

Field Summary

Fields

Modifier and Type	Field and Description
protected java.io.Closeable	current The current closeable.
protected boolean	done Indicate that this container was closed.
protected java.util.concurrent.locks.Lock	lock The lock guarding the contents.

Constructor Summary

Constructors

Constructor and Description
SequentialCloseable()

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeSilently() Closes this container silently.
java.io.Closeable	get()
boolean	isClosed()
void	set(java.io.Closeable c) Replaces the current closeable with the new closeable.

Methods inherited from class java.lang.Object

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

Field Detail

lock

protected final java.util.concurrent.locks.Lock lock

The lock guarding the contents.

current

protected java.io.Closeable current

The current closeable.

done

protected boolean done

Indicate that this container was closed.

Constructor Detail

SequentialCloseable

public SequentialCloseable()

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

get

@Nullable
public java.io.Closeable get()

Returns:

the currently managed closeable

set

public void set(@Nullable
                java.io.Closeable c)

Replaces the current closeable with the new closeable. The old closeable is closed. If the container is already closed, the c will be closed immediately.

Parameters:

c - the closeable

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Cancelable

Returns:

true if the object has been closed.

closeSilently

public void closeSilently()

Closes this container silently.