while

Documentation

Index

• func NewDropWhileSink(retainAndCountDroppedElements bool, predicate predicate.Predicater) *dropWhileSink
• type DropWhileOp
  • func NewDropWhileOp(sinkNewer func() DropWhileSink) *DropWhileOp
  • func NewDropWhileOp2(retainAndCountDroppedElements bool, predicate predicate.Predicater) *DropWhileOp
  • func (op DropWhileOp) EvaluateParallel(ctx context.Context, spliterator spliterator.Spliterator) optional.Optional
  • func (op DropWhileOp) EvaluateSequential(ctx context.Context, spliterator spliterator.Spliterator) optional.Optional
  • func (op DropWhileOp) MakeSink() DropWhileSink
• type DropWhileSink
• type DropWhileTask
  • func (task *DropWhileTask) DoLeaf(ctx context.Context) terminal.Sink
  • func (task *DropWhileTask) MakeChild(spliterator spliterator.Spliterator) terminal.Task
  • func (task *DropWhileTask) OnCompletion(caller terminal.Task)
  • func (task *DropWhileTask) WithParent(parent *DropWhileTask, spliterator spliterator.Spliterator) *DropWhileTask
  • func (task *DropWhileTask) WithSpliterator(op DropWhileOp, spliterator spliterator.Spliterator) *DropWhileTask

Functions

func NewDropWhileSink

func NewDropWhileSink(retainAndCountDroppedElements bool, predicate predicate.Predicater) *dropWhileSink

Types

type DropWhileOp

type DropWhileOp struct {
	terminal.TODOOperation
	// contains filtered or unexported fields
}

* * A specialization for the dropWhile operation that controls if * elements to be dropped are counted and passed downstream. * <p> * This specialization is utilized by the {@link TakeWhileTask} for * pipelines that are ordered. In such cases elements cannot be dropped * until all elements have been collected. * * @param <T> the type of both input and output elements

func NewDropWhileOp

func NewDropWhileOp(sinkNewer func() DropWhileSink) *DropWhileOp

func NewDropWhileOp2

func NewDropWhileOp2(retainAndCountDroppedElements bool, predicate predicate.Predicater) *DropWhileOp

func (DropWhileOp) EvaluateParallel

func (op DropWhileOp) EvaluateParallel(ctx context.Context, spliterator spliterator.Spliterator) optional.Optional

func (DropWhileOp) EvaluateSequential

func (op DropWhileOp) EvaluateSequential(ctx context.Context, spliterator spliterator.Spliterator) optional.Optional

func (DropWhileOp) MakeSink

func (op DropWhileOp) MakeSink() DropWhileSink

type DropWhileSink

type DropWhileSink interface {
	terminal.Sink
	/**
	 * @return the could of elements that would have been dropped and
	 * instead were passed downstream.
	 */
	GetDropCount() int
}

*

• A specialization for a dropWhile sink. *
• @param <T> the type of both input and output elements

type DropWhileTask

type DropWhileTask struct {
	terminal.TODOShortCircuitTask
	// contains filtered or unexported fields
}

func (*DropWhileTask) DoLeaf

func (task *DropWhileTask) DoLeaf(ctx context.Context) terminal.Sink

func (*DropWhileTask) MakeChild

func (task *DropWhileTask) MakeChild(spliterator spliterator.Spliterator) terminal.Task

func (*DropWhileTask) OnCompletion

func (task *DropWhileTask) OnCompletion(caller terminal.Task)

func (*DropWhileTask) WithParent

func (task *DropWhileTask) WithParent(parent *DropWhileTask, spliterator spliterator.Spliterator) *DropWhileTask

*

• Constructor for non-root nodes. *
• @param parent parent task in the computation tree
• @param spliterator the {@code Spliterator} for the portion of the
• computation tree described by this task

func (*DropWhileTask) WithSpliterator

func (task *DropWhileTask) WithSpliterator(op DropWhileOp, spliterator spliterator.Spliterator) *DropWhileTask

*

• Constructor for root tasks. *
• @param helper the {@code PipelineHelper} describing the stream pipeline
• up to this operation
• @param spliterator the {@code Spliterator} describing the source for this
• pipeline