Package tripleo.elijah_durable_congenial.comp

Class WritePipeline

java.lang.Object

tripleo.elijah_durable_congenial.comp.WritePipeline

All Implemented Interfaces:

Consumer<Supplier<GenerateResult>>, AccessBus.AB_GenerateResultListener, PipelineMember

public class WritePipeline
extends Object
implements PipelineMember, Consumer<Supplier<GenerateResult>>, AccessBus.AB_GenerateResultListener

Created 8/21/21 10:19 PM

Field Summary

Fields

Modifier and Type	Field	Description
final org.jdeferred2.impl.DeferredObject<GenerateResult,Void,Void>	generateResultPromise
final @NotNull WritePipelineSharedState	st

Constructor Summary

Constructors

Constructor	Description
WritePipeline(@NotNull IPipelineAccess pa)

Method Summary

Modifier and Type	Method	Description
void	accept(@NotNull Supplier<GenerateResult> aGenerateResultSupplier)
@NotNull Consumer<Supplier<GenerateResult>>	consumer()
void	gr_slot(@NotNull GenerateResult gr1)
void	run(CR_State aSt, CB_Output aOutput)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Field Details

generateResultPromise

public final org.jdeferred2.impl.DeferredObject<GenerateResult,Void,Void> generateResultPromise

st

@NotNull
public final @NotNull WritePipelineSharedState st

Constructor Details

WritePipeline

public WritePipeline(@NotNull
 @NotNull IPipelineAccess pa)

Method Details

accept

public void accept(@NotNull
 @NotNull Supplier<GenerateResult> aGenerateResultSupplier)

Specified by:

accept in interface Consumer<Supplier<GenerateResult>>

consumer

@NotNull
public @NotNull Consumer<Supplier<GenerateResult>> consumer()

gr_slot

public void gr_slot(@NotNull
 @NotNull GenerateResult gr1)

Specified by:

gr_slot in interface AccessBus.AB_GenerateResultListener

run

public void run(CR_State aSt,
 CB_Output aOutput)
         throws Exception

Specified by:

run in interface PipelineMember

Throws:

Exception