gopher
Type members
Classlikes
core of Gopher API. Given instance of Gopher[F] need for using most of Gopher operations.
core of Gopher API. Given instance of Gopher[F] need for using most of Gopher operations.
Gopher is a framework, which implements CSP (Communication Sequence Process). Process here - scala units of execution (i.e. functions, blok of code, etc). Communication channels represented by [gopher.Channel]
- See also
[gopher.Channel]
[gopher#select]
- Source
- Gopher.scala
- Companion
- object
- Source
- JVMGopher.scala
- Source
- JVMGopherConfig.scala
ReadChannel: Interface providing asynchronous reading API.
ReadChannel: Interface providing asynchronous reading API.
- Companion
- object
- Source
- ReadChannel.scala
Organize waiting for read/write from multiple async channels
Organize waiting for read/write from multiple async channels
Gopher[F] provide a function select of this type.
- Source
- Select.scala
Helper namespace for Select.Fold return value
Helper namespace for Select.Fold return value
- See also
[Select.fold]
- Source
- SelectFold.scala
Result of select.forever: apply method accept partial pseudofunction which evalueated forever.
Result of select.forever: apply method accept partial pseudofunction which evalueated forever.
- Source
- SelectForever.scala
Select group is a virtual 'lock' object. Readers and writers are grouped into select groups. When event about avaiability to read or to write is arrived and no current event group members is running, than run of one of the members is triggered. I.e. only one from group can run.
Select group is a virtual 'lock' object. Readers and writers are grouped into select groups. When event about avaiability to read or to write is arrived and no current event group members is running, than run of one of the members is triggered. I.e. only one from group can run.
Note, that application develeper usually not work with SelectGroup directly,
it is created internally by select pseudostatement.
- See also
[gopher.Select]
[gopher.select]
- Source
- SelectGroup.scala
Shared gopehr api, which is initialized by platofrm part, Primary used for cross-platforming test, you shoul initialize one of platform API behind and then run tests.
Shared gopehr api, which is initialized by platofrm part, Primary used for cross-platforming test, you shoul initialize one of platform API behind and then run tests.
- Source
- GopherAPI.scala
Time API, simular to one in golang standard library.
Time API, simular to one in golang standard library.
- See also
gopherApi#time
- Companion
- object
- Source
- Time.scala
Channel, where messages can be exprited.
Channel, where messages can be exprited.
Value members
Concrete methods
Create Read/Write channel.
Create Read/Write channel.
- Value Params
- autoClose
- close after first message was written to channel.
- bufSize
- size of buffer. If it is zero, the channel is unbuffered. (i.e. writer is blocked until reader start processing).
- See also
[gopher.Channel]
- Source
- Gopher.scala