FilteredAsyncChannel

class FilteredAsyncChannel[F[_], W, R](internal: Channel[F, W, R], p: R => F[Boolean]) extends FilteredAsyncReadChannel[F, R] with Channel[F, W, R]
trait Channel[F, W, R]
trait Closeable
trait AutoCloseable
trait WriteChannel[F, W]
trait ReadChannel[F, R]
class Object
trait Matchable
class Any

Type members

Inherited classlikes

class SimpleReader(f: Try[A] => Unit)
Inherited from
ReadChannel
Source
ReadChannel.scala

Inherited types

type done = Unit
Inherited from
ReadChannel
Source
ReadChannel.scala
type read = A

Special type which is used in select statement.

Special type which is used in select statement.

See also

[gopher.Select]

Inherited from
ReadChannel
Source
ReadChannel.scala
type write = A
Inherited from
WriteChannel
Source
WriteChannel.scala

Value members

Concrete methods

override
def addWriter(writer: Writer[W]): Unit
Definition Classes
Source
FilteredChannel.scala
override
def close(): Unit
Definition Classes
Closeable -> AutoCloseable
Source
FilteredChannel.scala
override
def isClosed: Boolean
Definition Classes
Source
FilteredChannel.scala

Inherited methods

@targetName("write2")
transparent inline
def !(inline a: W): Unit
Inherited from
WriteChannel
Source
WriteChannel.scala
@targetName("write1")
transparent inline
def <~(inline a: W): Unit
Inherited from
WriteChannel
Source
WriteChannel.scala
transparent inline
def ?: R

Synonim for read.

Synonim for read.

Inherited from
ReadChannel
Source
ReadChannel.scala
def aOptRead(): F[Option[R]]

read value and return future with

read value and return future with

  • Some(value) if value is available to read
  • None if stream is closed.
Inherited from
ReadChannel
Source
ReadChannel.scala
def addDoneReader(reader: Reader[Unit]): Unit
def addReader(reader: Reader[R]): Unit
def afold[S](s0: S)(f: (S, R) => S): F[S]
Inherited from
ReadChannel
Source
ReadChannel.scala
def afold_async[S](s0: S)(f: (S, R) => F[S]): F[S]
Inherited from
ReadChannel
Source
ReadChannel.scala
def aforeach(f: R => Unit): F[Unit]
Inherited from
ReadChannel
Source
ReadChannel.scala
def aforeach_async(f: R => F[Unit]): F[F[Unit]]
Inherited from
ReadChannel
Source
ReadChannel.scala
def append(other: ReadChannel[F, R]): ReadChannel[F, R]
Inherited from
ReadChannel
Source
ReadChannel.scala
def aread(): F[R]

async version of read. Immediatly return future, which will contains result of read or failur with StreamClosedException in case of stream is closed.

async version of read. Immediatly return future, which will contains result of read or failur with StreamClosedException in case of stream is closed.

Inherited from
ReadChannel
Source
ReadChannel.scala
def asyncMonad: CpsSchedulingMonad[F]
Inherited from
ReadChannel
Source
ReadChannel.scala
def atake(n: Int): F[IndexedSeq[R]]

return F which contains sequence from first n elements.

return F which contains sequence from first n elements.

Inherited from
ReadChannel
Source
ReadChannel.scala
def awrite(a: W): F[Unit]
Inherited from
WriteChannel
Source
WriteChannel.scala
def awriteAll(collection: IterableOnce[W]): F[Unit]
Inherited from
WriteChannel
Source
WriteChannel.scala
def dup(bufSize: Int, expiration: Duration): (ReadChannel[F, R], ReadChannel[F, R])
Inherited from
ReadChannel
Source
ReadChannel.scala
override
def filter(p: R => Boolean): Channel[F, W, R]
Definition Classes
Inherited from
Channel
Source
Channel.scala
override
def filterAsync(p: R => F[Boolean]): Channel[F, W, R]
Definition Classes
Inherited from
Channel
Source
Channel.scala
def flatMap[R1](f: R => ReadChannel[F, R1]): Channel[F, W, R1]
Inherited from
Channel
Source
Channel.scala
transparent inline
def fold[S](inline s0: S)(inline f: (S, R) => S): S
Inherited from
ReadChannel
Source
ReadChannel.scala
def fold_async[S](s0: S)(f: (S, R) => F[S]): F[S]
Inherited from
ReadChannel
Source
ReadChannel.scala
transparent inline
def foreach(inline f: R => Unit): Unit

run code each time when new object is arriced. until end of stream is not reached

run code each time when new object is arriced. until end of stream is not reached

Inherited from
ReadChannel
Source
ReadChannel.scala
def foreach_async(f: R => F[Unit]): F[Unit]
Inherited from
ReadChannel
Source
ReadChannel.scala
override
def map[R1](f: R => R1): Channel[F, W, R1]
Definition Classes
Inherited from
Channel
Source
Channel.scala
override
def mapAsync[R1](f: R => F[R1]): Channel[F, W, R1]
Definition Classes
Inherited from
Channel
Source
Channel.scala
transparent inline
def optRead(): Option[R]

read value and return

read value and return

  • Some(value) if value is available to read
  • None if stream is closed.

should be called inside async block.

Inherited from
ReadChannel
Source
ReadChannel.scala
def or(other: ReadChannel[F, R]): ReadChannel[F, R]
Inherited from
ReadChannel
Source
ReadChannel.scala
transparent inline
def read(): R

blocked read: if currently not element available - wait for one. Can be used only inside async block. If stream is closed and no values to read left in the stream - throws StreamClosedException

blocked read: if currently not element available - wait for one. Can be used only inside async block. If stream is closed and no values to read left in the stream - throws StreamClosedException

Inherited from
ReadChannel
Source
ReadChannel.scala
transparent inline
def take(n: Int): IndexedSeq[R]

take first n elements. should be called inside async block.

take first n elements. should be called inside async block.

Inherited from
ReadChannel
Source
ReadChannel.scala
def withExpiration(ttl: FiniteDuration, throwTimeouts: Boolean): ChannelWithExpiration[F, W, R]
Inherited from
Channel
Source
Channel.scala
def withWriteExpiration(ttl: FiniteDuration, throwTimeouts: Boolean)(using gopherApi: Gopher[F]): WriteChannelWithExpiration[F, W]
Inherited from
WriteChannel
Source
WriteChannel.scala
transparent inline
def write(inline a: W): Unit
Inherited from
WriteChannel
Source
WriteChannel.scala
transparent inline
def writeAll(inline collection: IterableOnce[W]): Unit
Inherited from
WriteChannel
Source
WriteChannel.scala
def zip[B](x: ReadChannel[F, B]): ReadChannel[F, (R, B)]
Inherited from
ReadChannel
Source
ReadChannel.scala
def |(other: ReadChannel[F, R]): ReadChannel[F, R]
Inherited from
ReadChannel
Source
ReadChannel.scala

Inherited fields

lazy
val done: ReadChannel[F, Unit]
Inherited from
ReadChannel
Source
ReadChannel.scala