hu.akarnokd.reactive4java.util

Class DefaultConnectableObservable.InnerConnection

java.lang.Object

hu.akarnokd.reactive4java.util.DefaultConnectableObservable.InnerConnection

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

DefaultConnectableObservable<T,U>

protected class DefaultConnectableObservable.InnerConnection
extends java.lang.Object
implements java.io.Closeable

The inner connection that nulls out the parent class' connection and deregisters the subject, but only once.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.io.Closeable	c The subject's close handler.

Constructor Summary

Constructors

Constructor and Description
InnerConnection(java.io.Closeable c) Constructor.

Method Summary

Modifier and Type	Method and Description
void	close()

Methods inherited from class java.lang.Object

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

Field Detail

c

@Nonnull
protected java.io.Closeable c

The subject's close handler.

Constructor Detail

InnerConnection

public InnerConnection(@Nonnull
                       java.io.Closeable c)

Constructor. Stores the subject's close handler.

Parameters:

c - the closeable

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