hu.akarnokd.reactive4java.util

Class ScheduledCloseable

java.lang.Object

hu.akarnokd.reactive4java.util.ScheduledCloseable

All Implemented Interfaces:

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

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

A closeable instance which invokes the managed closeable's close method on the given scheduler.

The implementation is thread-safe.

Since:

0.97

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicReference<java.io.Closeable>	current The handle reference.
protected Scheduler	scheduler The scheduler reference.
protected static java.io.Closeable	SENTINEL The empty sentinel to know when we have closed the previous instance and keep the invariants of this SingleCloseable.

Constructor Summary

Constructors

Constructor and Description
ScheduledCloseable(Scheduler scheduler, java.io.Closeable handle) Constructor.

Method Summary

Modifier and Type	Method and Description
void	close()
java.io.Closeable	get()
boolean	isClosed()
Scheduler	scheduler()

Methods inherited from class java.lang.Object

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

Field Detail

scheduler

@Nonnull
protected final Scheduler scheduler

The scheduler reference.

current

@Nonnull
protected final java.util.concurrent.atomic.AtomicReference<java.io.Closeable> current

The handle reference.

SENTINEL

@Nonnull
protected static final java.io.Closeable SENTINEL

The empty sentinel to know when we have closed the previous instance and keep the invariants of this SingleCloseable.

Constructor Detail

ScheduledCloseable

public ScheduledCloseable(@Nonnull
                          Scheduler scheduler,
                          @Nonnull
                          java.io.Closeable handle)

Constructor.

Parameters:

scheduler - the scheduler to use

handle - the handle to close

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

scheduler

@Nonnull
public Scheduler scheduler()

Returns:

the scheduler used.

get

@Nonnull
public java.io.Closeable get()

Returns:

the managed closeable

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Cancelable

Returns:

true if the object has been closed.