GetChan

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[I, A](blockingInput: I)(read: (I) ⇒ Option[(A, I)])(close: (I) ⇒ Unit): GetChan[A]

7. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

8. def blocking[I, A](executor: Executor)(blockingInput: I)(read: (I) ⇒ Option[(A, I)])(close: (I) ⇒ Unit): IChan[A]

9. def blocking[I, A](inputName: String)(blockingInput: I)(read: (I) ⇒ Option[(A, I)])(close: (I) ⇒ Unit): IChan[A]

10. def clone(): AnyRef

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws()

11. def empty[A]: GetChan[A]

    Construct a blocking input channel that terminates immediately with EOS

    Construct a blocking 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.

12. def empty[A](signal: Signal): GetChan[A]

    Construct a blocking input channel that terminates immediately with a signal

    Construct a blocking 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.

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

    Definition Classes

    AnyRef

14. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

15. def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws()

16. def from(br: BufferedReader): GetChan[String]

17. def from(br: BufferedReader, close: Boolean): GetChan[String]

18. def from(in: InputStream, bufferSize: Int, close: Boolean = true): GetChan[ByteBuffer]

19. implicit def getChanIsMessage[A]: Message[GetChan[A]]

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

    Definition Classes

    AnyRef → Any

21. def hashCode(): Int

    Definition Classes

    AnyRef → Any

22. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

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

    Definition Classes

    AnyRef

24. final def notify(): Unit

    Definition Classes

    AnyRef

25. final def notifyAll(): Unit

    Definition Classes

    AnyRef

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

    Definition Classes

    AnyRef

27. def toString(): String

    Definition Classes

    AnyRef → Any

28. def unapply(getChan: molecule.channel.GetChan[_]): Option[Signal]

29. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws()

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

    Definition Classes

    AnyRef

    Annotations

    @throws()

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

    Definition Classes

    AnyRef

    Annotations

    @throws()

32. def wrap[A](inputName: String, blockingChan: GetChan[A]): IChan[A]

33. def wrap[A](executor: Executor, getChan: GetChan[A]): IChan[A]