Documentation
¶
Index ¶
- func NewDropWhileSink(retainAndCountDroppedElements bool, predicate predicate.Predicater) *dropWhileSink
- type DropWhileOp
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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) 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
Source Files
Click to show internal directories.
Click to hide internal directories.