final class CQueue[F[+_], -A, +B] extends AnyRef
- See also
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- CQueue
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def awaitShutdown(implicit R: Runtime[Any], F: LiftIO[F]): F[Unit]
- See also
- def capacity: Int
- See also
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def contramap[C](f: (C) => A): CQueue[F, C, B]
- See also
- def contramapM[C](f: (C) => F[A])(implicit R: Runtime[Any], E: Effect[F]): CQueue[F, C, B]
- See also
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def filterInput[A0 <: A](f: (A0) => Boolean): CQueue[F, A0, B]
- See also
- def filterInputM[A0 <: A](f: (A0) => F[Boolean])(implicit R: Runtime[Any], E: Effect[F]): CQueue[F, A0, B]
- See also
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isShutdown(implicit R: Runtime[Any], F: LiftIO[F]): F[Boolean]
- See also
- def map[C](f: (B) => C): CQueue[F, A, C]
- See also
- def mapM[C](f: (B) => F[C])(implicit R: Runtime[Any], E: Effect[F]): CQueue[F, A, C]
- See also
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def offer(a: A)(implicit R: Runtime[Any], F: LiftIO[F]): F[Boolean]
- See also
- def offerAll(as: Iterable[A])(implicit R: Runtime[Any], F: LiftIO[F]): F[Boolean]
- See also
- def poll(implicit R: Runtime[Any], F: LiftIO[F]): F[Option[B]]
- See also
- def shutdown(implicit R: Runtime[Any], F: LiftIO[F]): F[Unit]
- See also
- def size(implicit R: Runtime[Any], F: LiftIO[F]): F[Int]
- See also
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def take(implicit R: Runtime[Any], F: LiftIO[F]): F[B]
- See also
- def takeAll(implicit R: Runtime[Any], F: LiftIO[F]): F[List[B]]
- See also
- def takeUpTo(max: Int)(implicit R: Runtime[Any], F: LiftIO[F]): F[List[B]]
- See also
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
Deprecated Value Members
- def &&[A0 <: A, C](that: CQueue[F, A0, C]): CQueue[F, A0, (B, C)]
- Annotations
- @deprecated
- Deprecated
(Since version 2.0.0) use ZStream
- See also
- def both[A0 <: A, C](that: CQueue[F, A0, C]): CQueue[F, A0, (B, C)]
- Annotations
- @deprecated
- Deprecated
(Since version 2.0.0) use ZStream
- See also
- def bothWith[A0 <: A, C, D](that: CQueue[F, A0, C])(f: (B, C) => D): CQueue[F, A0, D]
- Annotations
- @deprecated
- Deprecated
(Since version 2.0.0) use ZStream
- See also
- def bothWithM[A0 <: A, C, D](that: CQueue[F, A0, C])(f: (B, C) => F[D])(implicit R: Runtime[Any], E: Effect[F]): CQueue[F, A0, D]
- Annotations
- @deprecated
- Deprecated
(Since version 2.0.0) use ZStream
- See also