ChannelResult

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. def ++[B >: A](ch2: ChannelResult[R, B]): ChannelResult[R, B]

   alias for append of ChannelResult *

5. def ++[B >: A]()(p2: ⇒ Process[Task, B]): ChannelResult[R, B]

   applies scalaz.stream.Process.append on resulting stream *

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

   Definition Classes

   AnyRef

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

   Definition Classes

   Any

8. def append[B >: A](ch2: ChannelResult[R, B]): ChannelResult[R, B]

   append variant taking the ChannelResult as its second argument.

   append variant taking the ChannelResult as its second argument. Please note her that the argument is strict *

9. def append[B >: A](p2: ⇒ Process[Task, B]): ChannelResult[R, B]

   applies scalaz.stream.Process.append on resulting stream *

10. final def asInstanceOf[T0]: T0

    Definition Classes

    Any

11. def attempt[B](f: (Throwable) ⇒ Process[Task, B] = (t: Throwable) => emit(t)): ChannelResult[R, \/[B, A]]

    applies scalaz.stream.Process.attempt on resulting stream *

12. def causedBy[B >: A](e: Throwable): ChannelResult[R, B]

    applies scalaz.stream.Process.causedBy on resulting stream *

13. val channel: Process.Channel[Task, R, Process[Task, A]]

14. def clone(): AnyRef

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

15. def disconnect: ChannelResult[R, A]

    applies scalaz.stream.Process.disconnect on resulting stream *

16. def drain: ChannelResult[R, Nothing]

    applies scalaz.stream.Process.drain on resulting stream *

17. def either[B >: A, C](p2: Process[Task, C]): ChannelResult[R, \/[B, C]]

    applies scalaz.stream.Process.either on resulting stream *

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

    Definition Classes

    AnyRef

19. def fallback: ChannelResult[R, A]

    applies scalaz.stream.Process.fallback on resulting stream *

20. def fby[B >: A](p2: ⇒ Process[Task, B]): ChannelResult[R, B]

    applies scalaz.stream.Process.then on resulting stream *

21. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

22. def flatMap[B](f: (A) ⇒ ChannelResult[R, B]): ChannelResult[R, B]

    binds other ChanelResult to this ChannelResult *

23. def flatMapProcess[B](f: (A) ⇒ Process[Task, B]): ChannelResult[R, B]

    applies scalaz.stream.Process.flatMap on resulting stream *

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

    Definition Classes

    AnyRef → Any

25. def handle[B](f: PartialFunction[Throwable, Process[Task, B]]): ChannelResult[R, B]

    applies scalaz.stream.Process.handle on resulting stream *

26. def hardDisconnect: ChannelResult[R, A]

    applies scalaz.stream.Process.hardDisconnect on resulting stream *

27. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

28. def kill: ChannelResult[R, Nothing]

    applies scalaz.stream.Process.kill on resulting stream *

29. def killBy(e: Throwable): ChannelResult[R, Nothing]

    applies scalaz.stream.Process.killBy on resulting stream *

30. def map[B](f: (A) ⇒ B): ChannelResult[R, B]

    applies scalaz.stream.Process.map on resulting stream *

31. def merge[B >: A](p2: Process[Task, B]): ChannelResult[R, B]

    applies scalaz.stream.Process.merge on resulting stream *

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

    Definition Classes

    AnyRef

33. final def notify(): Unit

    Definition Classes

    AnyRef

34. final def notifyAll(): Unit

    Definition Classes

    AnyRef

35. def onComplete[B >: A](p2: ⇒ Process[Task, B]): ChannelResult[R, B]

    applies scalaz.stream.Process.onComplete on resulting stream *

36. def onFailure[B >: A](p2: ⇒ Process[Task, B]): ChannelResult[R, B]

    applies scalaz.stream.Process.onFailure on resulting stream *

37. def orElse[B >: A](fallback: ⇒ Process[Task, B], cleanup: ⇒ Process[Task, B] = halt): ChannelResult[R, B]

    applies scalaz.stream.Process.orElse on resulting stream *

38. def partialAttempt[B](f: PartialFunction[Throwable, Process[Task, B]]): ChannelResult[R, \/[B, A]]

    applies scalaz.stream.Process.partialAttempt on resulting stream *

39. def pipe[B](p2: Process.Process1[A, B]): ChannelResult[R, B]

    applies scalaz.stream.Process.pipe on resulting stream *

40. def repeat[B >: A]: ChannelResult[R, B]

    applies scalaz.stream.Process.repeat on resulting stream *

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

    Definition Classes

    AnyRef

42. def tee[B, C](p2: Process[Task, B])(t: Process.Tee[A, B, C]): ChannelResult[R, C]

    applies scalaz.stream.Process.tee on resulting stream *

43. def through[B](p: Process.Channel[Task, A, B]): ChannelResult[R, B]

    applies scalaz.stream.Process.ProcessSyntax.through on resulting stream *

44. def to(p: Process.Sink[Task, A]): ChannelResult[R, Unit]

    applies scalaz.stream.Process.ProcessSyntax.to on resulting stream *

45. def trim: ChannelResult[R, A]

    applies scalaz.stream.Process.trim on resulting stream *

46. def until[B >: A](condition: Process[Task, Boolean]): ChannelResult[R, B]

    applies scalaz.stream.Process.until on resulting stream *

47. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

50. def when[B >: A](condition: Process[Task, Boolean]): ChannelResult[R, B]

    applies scalaz.stream.Process.when on resulting stream *

51. def wye[B, C](p2: Process[Task, B])(y: Process.Wye[A, B, C]): ChannelResult[R, C]

    applies scalaz.stream.Process.wye on resulting stream *

52. def yip[B](p2: Process[Task, B]): ChannelResult[R, (A, B)]

    applies scalaz.stream.Process.yip on resulting stream *

53. def yipWith[B, C](p2: Process[Task, B])(f: (A, B) ⇒ C): ChannelResult[R, C]

    applies scalaz.stream.Process.yipWith on resulting stream *

54. def zip[B](ch2: ChannelResult[R, B]): ChannelResult[R, (A, B)]

    zips two channels together

55. def zip[B](p2: Process[Task, B]): ChannelResult[R, (A, B)]

    applies scalaz.stream.Process.zip on resulting stream *

56. def zipWith[B, C](ch2: ChannelResult[R, B])(f: (A, B) ⇒ C): ChannelResult[R, C]

    zips inner processes of ChannelResults

57. def zipWith[B, C](p2: Process[Task, B])(f: (A, B) ⇒ C): ChannelResult[R, C]

    applies scalaz.stream.Process.zipWith on resulting stream *

58. def |>[B](p2: Process.Process1[A, B]): ChannelResult[R, B]

    applies scalaz.stream.Process.pipe on resulting stream *