uk.co.strangeskies.observable

Class ReferenceOwnedObserver<O,M>

java.lang.Object

uk.co.strangeskies.observable.PassthroughObserver<M,OwnedMessage<O,M>>

uk.co.strangeskies.observable.ReferenceOwnedObserver<O,M>

All Implemented Interfaces:

Observer<M>

public class ReferenceOwnedObserver<O,M>
extends PassthroughObserver<M,OwnedMessage<O,M>>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ReferenceOwnedObserver(O owner, Observer<? super OwnedMessage<O,M>> downstreamObserver, java.util.function.Function<O,java.lang.ref.Reference<O>> referenceFunction)

Method Summary

Modifier and Type	Method and Description
void	onNext(M message) The method which will receive notification from an Observable.
static <O,M> ReferenceOwnedObserver<O,M>	soft(O owner, Observer<? super OwnedMessage<O,M>> downstreamObserver)
static <O,M> ReferenceOwnedObserver<O,M>	weak(O owner, Observer<? super OwnedMessage<O,M>> downstreamObserver)
void	withOwner(java.util.function.Consumer<O> action)

Methods inherited from class uk.co.strangeskies.observable.PassthroughObserver

getDownstreamObserver, getObservation, initializeObservation, onComplete, onFail, onObserve

Methods inherited from class java.lang.Object

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

Methods inherited from interface uk.co.strangeskies.observable.Observer

onCompletion, onFailure, onObservation, singleUse

Constructor Detail

ReferenceOwnedObserver

protected ReferenceOwnedObserver(O owner,
                                 Observer<? super OwnedMessage<O,M>> downstreamObserver,
                                 java.util.function.Function<O,java.lang.ref.Reference<O>> referenceFunction)

Method Detail

weak

public static <O,M> ReferenceOwnedObserver<O,M> weak(O owner,
                                                     Observer<? super OwnedMessage<O,M>> downstreamObserver)

soft

public static <O,M> ReferenceOwnedObserver<O,M> soft(O owner,
                                                     Observer<? super OwnedMessage<O,M>> downstreamObserver)

withOwner

public void withOwner(java.util.function.Consumer<O> action)

onNext

public void onNext(M message)

Description copied from interface: Observer

The method which will receive notification from an Observable.

Specified by:

onNext in interface Observer<M>

Specified by:

onNext in class PassthroughObserver<M,OwnedMessage<O,M>>

Parameters:

message - the message object instance