t

Stream.Flow._extend._peek

trait _peek[A] extends AnyRef

Inspection Interface.

'peek' methods do not change Flow type or composition.

Self Type
Stream.Flow[A]
Ordering
  1. Alphabetic
Inherited
  1. Flow._extend._peek
  2. scala.AnyRef
  3. scala.Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Method

  1. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  2. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  3. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  4. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  5. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  6. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  7. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  8. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. final def notify(): Unit
    Definition Classes
    AnyRef
  10. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  11. abstract def peek(c: Consumer[A]): Flow[A]

    Element access

    Element access

    Provides access to passing pipeline elements

    This method does not change pipeline type or composition in any way

    ('A' <> 'C').all.peek("Passing: " + _ lp).count.lp
    
    // Output
    Passing: A
    Passing: B
    Passing: C
    3
    Definition Classes
    _peek
  12. def peekIdx(c: Consumer.Idx[A], start: Int = 0): Flow[A]

    Indexed element access

    Indexed element access

    Provides access to passing pipeline elements with their index in sequence

    start

    starting value for element indexing

    ('A' <> 'C').all.peekIdx("Peek" + _ + " = " + _ lp).count.lp
    
    // Output
    Peek 0 = A
    Peek 1 = B
    Peek 2 = C
    3
    Definition Classes
    _peek
  13. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  14. def toString(): String
    Definition Classes
    AnyRef → Any
  15. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  16. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  17. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Operator

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any