Documentation ¶ Index ¶ type ConsumePipe func Consume() *ConsumePipe func (p *ConsumePipe) Run(ctx context.Context, state *types.State) (*types.State, error) type DiscardPipe func Discard() *DiscardPipe func (p *DiscardPipe) Run(ctx context.Context, state *types.State) (*types.State, error) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type ConsumePipe ¶ type ConsumePipe struct { *common.BasePipe } func Consume ¶ func Consume() *ConsumePipe func (*ConsumePipe) Run ¶ func (p *ConsumePipe) Run(ctx context.Context, state *types.State) (*types.State, error) type DiscardPipe ¶ type DiscardPipe struct { *common.BasePipe } func Discard ¶ func Discard() *DiscardPipe func (*DiscardPipe) Run ¶ func (p *DiscardPipe) Run(ctx context.Context, state *types.State) (*types.State, error) Source Files ¶ View all Source files consume.godiscard.go Click to show internal directories. Click to hide internal directories.