IChan

Value Members

1. final def !=(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

2. final def !=(arg0: Any): Boolean

   Definition Classes

   Any

3. final def ##(): Int

   Definition Classes

   AnyRef → Any

4. final def ==(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

5. final def ==(arg0: Any): Boolean

   Definition Classes

   Any

6. def apply(r: Range): IChan[Int]

7. def apply[A](a: A, as: A*)(implicit arg0: Message[A]): IChan[A]

   Creates a stream with the specified elements.

   Creates a stream with the specified elements.

   A

   the type of the stream's elements

   a

   the first elements of the created stream

   as

   the remaining elements of the created stream

   returns

   a new stream with the elements passed as parameters

8. def apply[A](seg: Seg[A], signal: Signal)(implicit arg0: Message[A]): IChan[A]

   Create a channel that returns a single segment.

   Create a channel that returns a single segment.

   A

   the type of the messages carried by the input channel.

   seg

   the segment read on the channel.

   signal

   the termination signal.

   returns

   an input channel that contains a single segment.

9. def apply[A](a: A, tail: ⇒ IChan[A])(implicit arg0: Message[A]): IChan[A]

   Create an input channel that generates data lazily out of main memory.

   Create an input channel that generates data lazily out of main memory.

   A

   the type of the messages carried by the input channel.

   a

   the first message read on the channel.

   tail

   the remainder of the channel.

   returns

   an input channel with a segment prepended.

10. final def asInstanceOf[T0]: T0

    Definition Classes

    Any

11. def bind[A](first: IChan[A], next: (A, Signal) ⇒ IChan[A])(implicit arg0: Message[A]): IChan[A]

12. def clone(): AnyRef

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws()

13. def cons[A](seg: Seg[A], tail: ⇒ IChan[A])(implicit arg0: Message[A]): IChan[A]

    Create a, input channel that generates data lazily out of main memory.

    Create a, input channel that generates data lazily out of main memory.

    A

    the type of the messages carried by the input channel.

    seg

    the segment to prepend to the channel.

    tail

    the original input channel.

    returns

    an input channel with a segment prepended.

14. def cons_(implicit arg0: Message[A]): IChan[A]

    Prepend a segment in front of an existing input channel.

    Prepend a segment in front of an existing input channel.

    A

    the type of the messages carried by the input channel.

    seg

    the segment to prepend to the channel.

    tail

    the original input channel.

    returns

    an input channel with a segment prepended.

15. def continually[A](elem: ⇒ A)(implicit arg0: Message[A]): IChan[A]

    Create an infinite stream containing the given element expression (which is computed for each occurrence)

    Create an infinite stream containing the given element expression (which is computed for each occurrence)

    elem

    the element composing the resulting stream

    returns

    the stream containing an infinite number of elem // TODO add iterator seg

16. def empty[A]: IChan[A]

    Construct a input channel that terminates immediately with EOS

    Construct a input channel that terminates immediately with EOS

    A

    the type of the messages carried by the input channel.

    returns

    An input channel that terminates immediately.

17. def empty[A](signal: Signal): IChan[A]

    Construct a input channel that terminates immediately with a signal

    Construct a input channel that terminates immediately with a signal

    A

    the type of the messages carried by the input channel.

    signal

    the termination signal.

    returns

    An input channel that terminates immediately.

18. final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

19. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

20. def fill[A](n: Int)(elem: ⇒ A)(implicit arg0: Message[A]): IChan[A]

    Create an stream of fixed size containing the given element expression which is computed at the time the channel is read

    Create an stream of fixed size containing the given element expression which is computed at the time the channel is read

    elem

    the element composing the resulting stream

    returns

    the stream containing an infinite number of elem

21. def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws()

22. def from(start: Int): IChan[Int]

    Create an infinite stream starting at start and incrementing by 1.

    Create an infinite stream starting at start and incrementing by 1.

    start

    the start value of the stream

    returns

    the stream starting at value start.

23. def from(start: Int, step: Int): IChan[Int]

    Create an infinite stream starting at start and incrementing by step step

    Create an infinite stream starting at start and incrementing by step step

    start

    the start value of the stream

    step

    the increment value of the stream

    returns

    the stream starting at value start.

24. final def getClass(): java.lang.Class[_]

    Definition Classes

    AnyRef → Any

25. def hashCode(): Int

    Definition Classes

    AnyRef → Any

26. implicit def ichanIsMessage[A]: Message[IChan[A]]

27. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

28. def iterate[A](start: A)(f: (A) ⇒ A)(implicit arg0: Message[A]): IChan[A]

    An infinite stream that repeatedly applies a given function to a start value.

    An infinite stream that repeatedly applies a given function to a start value.

    start

    the start value of the stream

    f

    the function that's repeatedly applied

    returns

    the stream returning the infinite sequence of values start, f(start), f(f(start)), ...

29. def lazily[A](elem: ⇒ A): IChan[A]

    Create an infinite stream containing the given element expression which is computed at the time the channel is read.

    Create an infinite stream containing the given element expression which is computed at the time the channel is read. Contrarily to continually, this channels emits one message at a time.

    elem

    the element composing the resulting stream

    returns

    the stream containing an infinite number of elem

30. final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

31. final def notify(): Unit

    Definition Classes

    AnyRef

32. final def notifyAll(): Unit

    Definition Classes

    AnyRef

33. def source[A](as: Traversable[A], sst: Int)(implicit arg0: Message[A]): IChan[A]

34. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

35. def tabulate[A](n: Int)(f: (Int) ⇒ A)(implicit arg0: Message[A]): IChan[A]

    Produces a stream containing values of a given function over a range of integer values starting from 0.

    Produces a stream containing values of a given function over a range of integer values starting from 0.

    n

    The number of elements to generate.

    f

    The function computing element values

    returns

    A new stream consisting of elements f(0), ..., f(n -1)

36. def toString(): String

    Definition Classes

    AnyRef → Any

37. def unapply(ichan: molecule.channel.IChan[_]): Option[Signal]

38. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws()

39. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws()

40. final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws()