root/gopher/WriteChannel

WriteChannel

trait WriteChannel[F[_], A]
Source
WriteChannel.scala
class Object
trait Matchable
class Any
trait Channel[F, W, R]
class ChannelWithExpiration[F, W, R]
class ChFlatMappedChannel[F, W, RA, RB]
class FilteredAsyncChannel[F, W, R]
class FilteredChannel[F, W, R]
class MappedAsyncChannel[F, W, RA, RB]
class MappedChannel[F, W, RA, RB]
class PromiseChannel[F, A]

Type members

Types

type write = A

Value members

Abstract methods

def addWriter(writer: Writer[A]): Unit
def asyncMonad: CpsAsyncMonad[F]

Concrete methods

@targetName("write2")
transparent inline
def !(inline a: A): Unit
@targetName("write1")
transparent inline
def <~(inline a: A): Unit
def awrite(a: A): F[Unit]
def awriteAll(collection: IterableOnce[A]): F[Unit]
def withWriteExpiration(ttl: FiniteDuration, throwTimeouts: Boolean)(using gopherApi: Gopher[F]): WriteChannelWithExpiration[F, A]
transparent inline
def write(inline a: A): Unit
transparent inline
def writeAll(inline collection: IterableOnce[A]): Unit