gopher.impl
Type members
Classlikes
Input, which reed from the first channel, and after first channel is closed - from second
Input, which reed from the first channel, and after first channel is closed - from second
can be created with 'append' operator.
val x = read(x|y)
- Source
- AppendReadChannel.scala
Object, which can be expired (usually - reader or writer in SelectGroup) Usage protocol is next: capture if A inside is used, call markUsed and use A if A inside is unused for some reason -- call markFree
Object, which can be expired (usually - reader or writer in SelectGroup) Usage protocol is next: capture if A inside is used, call markUsed and use A if A inside is unused for some reason -- call markFree
- Companion
- object
- Source
- Expirable.scala
- Source
- FilteredChannel.scala
- Source
- FilteredChannel.scala
Guarded channel work in the next way: reader and writer asynchronically added to readers and writers and force evaluation of internal step function or ensure that currently running step function will see the chanes in readers/writers. Step functions is executed in some thread loop, and in the same time, only one instance of step function is running. (which is ensured by guard)
Guarded channel work in the next way: reader and writer asynchronically added to readers and writers and force evaluation of internal step function or ensure that currently running step function will see the chanes in readers/writers. Step functions is executed in some thread loop, and in the same time, only one instance of step function is running. (which is ensured by guard)
- Companion
- object
- Source
- GuardedSPSCBaseChannel.scala
- Source
- MappedChannel.scala
- Source
- MappedReadChannel.scala
- Source
- MappedChannel.scala
- Source
- MappedReadChannel.scala
Input, which combine two other inputs.
Input, which combine two other inputs.
can be created with '|' operator.
val x = read(x|y)
- Source
- OrReadChannel.scala
Channel is closed immediatly after successfull write.
Channel is closed immediatly after successfull write.
- Source
- PromiseChannel.scala
Buffer. access to buffer is exclusive by owner channel, different loops can start in different threads but only one loop can be active at the samw time
Buffer. access to buffer is exclusive by owner channel, different loops can start in different threads but only one loop can be active at the samw time
- Source
- SPSCBuffer.scala