hu.akarnokd.reactive4java.util

Class ObserverToIteratorSink<T,U>

java.lang.Object

hu.akarnokd.reactive4java.util.ObserverToIteratorSink<T,U>

Type Parameters:

T - the observed type

U - the returned value type

All Implemented Interfaces:

BaseObserver, CloseableIterator<U>, Observer<T>, java.io.Closeable, java.lang.AutoCloseable, java.util.Iterator<U>

public abstract class ObserverToIteratorSink<T,U>
extends java.lang.Object
implements Observer<T>, CloseableIterator<U>

Base class to help transition from reactive to interactive world.

Since:

0.97

Field Summary

Fields

Modifier and Type	Field and Description
protected SingleOption<U>	current The current value.
protected boolean	done Indicate that the stream has finished.
protected java.io.Closeable	handle The original handle to the observer registration.

Constructor Summary

Constructors

Constructor and Description
ObserverToIteratorSink(java.io.Closeable handle) Constructor, saves the handle.

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	done() Closes this iterator and suppresses exceptions.
boolean	hasNext()
U	next()
void	remove()
abstract boolean	tryNext(SingleOption<? super U> out) Try to get the next value.

Methods inherited from class java.lang.Object

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

Methods inherited from interface hu.akarnokd.reactive4java.base.Observer

next

Methods inherited from interface hu.akarnokd.reactive4java.base.BaseObserver

error, finish

Methods inherited from interface java.util.Iterator

forEachRemaining

Field Detail

done

protected boolean done

Indicate that the stream has finished.

handle

@Nonnull
protected final java.io.Closeable handle

The original handle to the observer registration.

current

@Nonnull
protected final SingleOption<U> current

The current value.

Constructor Detail

ObserverToIteratorSink

public ObserverToIteratorSink(@Nonnull
                              java.io.Closeable handle)

Constructor, saves the handle.

Parameters:

handle - the handle to close when the stream finishes.

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<U>

next

public U next()

Specified by:

next in interface java.util.Iterator<U>

remove

public void remove()

Specified by:

remove in interface java.util.Iterator<U>

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

done

protected void done()

Closes this iterator and suppresses exceptions.

tryNext

public abstract boolean tryNext(@Nonnull
                                SingleOption<? super U> out)

Try to get the next value.

Parameters:

out - the output where to put the value

Returns:

true if value was available