public class LayingPipe
extends java.lang.Object

Nested Classes
Modifier and Type	Class	Description
`static class`	`LayingPipe.DisorderedPipeLaying`
`static class`	`LayingPipe.IncompatiblePipeLaying`
`static class`	`LayingPipe.IncompletePipeLaying`
`static class`	`LayingPipe.PipeLayingException`

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`apply()`
`<O extends Observation> LayingPipe`	`export(java.util.function.Consumer<Observable<O>> consumer)`
`LayingPipe`	`giveBackgroundThread()`
`static LayingPipe`	`inst()`
`static LayingPipe`	`inst(RegularScheduler regularScheduler, BackgroundTaskRunner backgroundTaskRunner)`
`static void`	`link(Observable<?> source, Observer<?> sink)`
`LayingPipe`	`pipe(ObservationPipe<?,?> pipe)`
`LayingPipe`	`schedule(java.time.Duration interval)`
`LayingPipe`	`setConstantRunner(BackgroundTaskRunner backgroundTaskRunner)`
`LayingPipe`	`setRegularRunner(RegularScheduler regularScheduler)`
`LayingPipe`	`sink(Observer<?> sink)`
`LayingPipe`	`sinks(Observer<?>... sinks)`
`LayingPipe`	`source(Observable<?> source)`
`LayingPipe`	`split(java.util.function.Consumer<LayingPipe> splitPath)`
`void`	`terminalSink(Observer<?> sink)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

public static LayingPipe inst(RegularScheduler regularScheduler,
                              BackgroundTaskRunner backgroundTaskRunner)

public static void link(Observable<?> source,
                        Observer<?> sink)

public LayingPipe setRegularRunner(RegularScheduler regularScheduler)

public LayingPipe setConstantRunner(BackgroundTaskRunner backgroundTaskRunner)

public LayingPipe source(Observable<?> source)

public LayingPipe pipe(ObservationPipe<?,?> pipe)

public LayingPipe split(java.util.function.Consumer<LayingPipe> splitPath)

public <O extends Observation> LayingPipe export(java.util.function.Consumer<Observable<O>> consumer)

public LayingPipe sink(Observer<?> sink)

public LayingPipe sinks(Observer<?>... sinks)

public void terminalSink(Observer<?> sink)

public void apply()
           throws LayingPipe.IncompletePipeLaying

public LayingPipe schedule(java.time.Duration interval)

public LayingPipe giveBackgroundThread()

Class LayingPipe