JVMGopher

class JVMGopher[F[_]](cfg: JVMGopherConfig)(implicit evidence$1: CpsSchedulingMonad[F]) extends Gopher[F]
Companion
object
Source
JVMGopher.scala
trait Gopher[F]
class Object
trait Matchable
class Any

Type members

Inherited types

type Monad[X] = F[X]
Inherited from
Gopher
Source
Gopher.scala

Value members

Concrete methods

def log(level: Level, message: String, ex: Throwable | Null): Unit
def makeChannel[A](bufSize: Int, autoClose: Boolean): Channel[F, A, A]
def scheduledExecutor: ScheduledExecutorService
def setLogFun(logFun: (Level, String, Throwable | Null) => Unit): (Level, String, Throwable | Null) => Unit

Inherited methods

def asyncMonad: CpsSchedulingMonad[F]

Monad which control asynchronic execution. The main is scheduling: i.e. ability to submit monadic expression to scheduler and know that this monadic expression will be evaluated.

Monad which control asynchronic execution. The main is scheduling: i.e. ability to submit monadic expression to scheduler and know that this monadic expression will be evaluated.

Inherited from
Gopher
Source
Gopher.scala
def log(level: Level, message: String): Unit
Inherited from
Gopher
Source
Gopher.scala
def makeOnceChannel[A](): Channel[F, A, A]

Create channel where you can write only one element.

Create channel where you can write only one element.

See also

[gopher.Channel]

Inherited from
Gopher
Source
Gopher.scala
def select: Select[F]

Create a select statement, which used for choosing one action from a set of potentially concurrent asynchronics events. [@see gopher.Select]

Create a select statement, which used for choosing one action from a set of potentially concurrent asynchronics events. [@see gopher.Select]

Inherited from
Gopher
Source
Gopher.scala

Concrete fields

lazy
val taskExecutionContext: ExecutionContext
val time: Time[F]