Package org.apache.sis.internal.stream

Class DeferredStream.CloseHandler

java.lang.Object

org.apache.sis.internal.stream.DeferredStream.CloseHandler

All Implemented Interfaces:

Runnable

Enclosing class:

DeferredStream<T>

private static final class DeferredStream.CloseHandler
extends Object
implements Runnable

Implementation of DeferredStream.closeHandler. This class allows to invoke BaseStream.onClose(Runnable) early while specifying the actual close action later, at DeferredStream.createSourceIterator() invocation time. This is necessary because it is too late to register a close handler on the stream when the worker is created, because the terminal operation already started at that time.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) AutoCloseable	handler	Handler to run for releasing resources, or null if none.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	CloseHandler()

Method Summary

Modifier and Type	Method	Description
void	run()	Invoked by the stream for disposing the resources.

Methods inherited from class java.lang.Object

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

Field Details

handler

AutoCloseable handler

Handler to run for releasing resources, or null if none. This is reset to null after usage.

See Also:

• DeferredStream.setCloseHandler(AutoCloseable)

Constructor Details

CloseHandler

private CloseHandler()

Method Details

run

public void run()

Invoked by the stream for disposing the resources.

Specified by:

run in interface Runnable