Top Fields Constructors Methods
org.reactfx

pack-priv Class ThreadBridge<T>

extends EventStreamBase<T>
Class Inheritance
Imports
java.util.concurrent.CompletableFuture, .Executor

Field Summary

Modifier and TypeField and Description
private final EventStream<T>
input

private final Executor
sourceThreadExecutor

private final Executor
targetThreadExecutor

Constructor Summary

AccessConstructor and Description
public
ThreadBridge(EventStream<T> input, Executor sourceThreadExecutor, Executor targetThreadExecutor)

Method Summary

Modifier and TypeMethod and Description
protected Subscription
observeInputs()

Implements abstract org.reactfx.ObservableBase.observeInputs.

Starts observing this observable's input(s), if any.

Field Detail

inputback to summary
private final EventStream<T> input
sourceThreadExecutorback to summary
private final Executor sourceThreadExecutor
targetThreadExecutorback to summary
private final Executor targetThreadExecutor

Constructor Detail

ThreadBridgeback to summary
public ThreadBridge(EventStream<T> input, Executor sourceThreadExecutor, Executor targetThreadExecutor)

Method Detail

observeInputsback to summary
protected Subscription observeInputs()

Implements abstract org.reactfx.ObservableBase.observeInputs.

Doc from org.reactfx.ObservableBase.observeInputs.

Starts observing this observable's input(s), if any. This method is called when the number of observers goes from 0 to 1. This method is called before newObserver(Object) is called for the first observer.

Annotations
@Override