Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Primetalk/goio
/ types & classes
Types & classes
31 in github.com/Primetalk/goio
⨍
Functions
426
◇
Types & classes
31
Interface
Any
fun/cast.go:3
Struct
BackpressureChannel
BackpressureChannel has a control mechanism that allows consumer to influence the producer. There is a back pressure channel. Protocol: sender
stream/backpressure_channels.go:46
FuncType
Callback
Callback[A] is a function that takes A and error. A is only valid if error is nil.
io/async.go:4
Struct
Closable
Closable is a value that is accompanied with the Close(). This is an internal structure that should not be used outside of the resource package.
resource/resource.go:13
Interface
ClosableIO
ClosableIO is a simple resource that implements Close method.
resource/closable_io.go:6
FuncType
Collector
Collector reads the stream and produces some value.
stream/execution.go:14
FuncType
Consumer
Consumer can receive an instance of A and perform some operation on it.
io/consumer.go:4
FuncType
Continuation
Continuation represents some multistep computation. It is being used to avoid stack overflow. It's a universal way to do "trampolining".
io/continuation.go:12
Struct
Either
Either is a simple data structure that can have either left value or right value.
either/either.go:6
Interface
ExecutionContext
ExecutionContext is a resource capable of running tasks in parallel. NB! This is not a safe resource and it is not intended to be used directly.
io/execution_context.go:19
Interface
Fiber
Fiber[A] is a type safe representation of Go routine. One might Join() and receive the result of the go routine. After Close() subsequent joins will f
io/fiber.go:14
Struct
GoResult
GoResult[A] is a data structure that represents the Go-style result of a function that could fail.
io/goresult.go:5
TypeAlias
IO
IO[A] represents a calculation that will yield a value of type A once executed. The calculation might as well fail. It is designed to not panic ever.
io/io.go:14
Interface
Number
Number is a generic number interface that covers all Go number types.
fun/numbers.go:6
Struct
Option
Option[A] can represent a value or an absent value of type A.
option/option.go:7
Struct
Pair
Pair is a data structure that has two values.
fun/pair.go:4
FuncType
Pipe
Pipe is a conversion of one stream to another. Technically it's a function that takes one stream and returns another.
stream/pipe.go:10
FuncType
Predicate
Predicate is a function with a boolean result type.
fun/predicate.go:4
TypeAlias
Resource
Resource[A] is an structure that can only be _used_ via Use. Unfortunately, it's not an interface, because interface methods do not support generics a
resource/resource.go:21
Struct
ResultOrContinuation
ResultOrContinuation is either a final result (value or error) or another continuation.
io/continuation.go:15
FuncType
Runnable
Runnable is a computation that performs some side effect and takes care of errors and panics. It task should never fail. In case it fails, application
io/execution_context.go:15
TypeAlias
Set
Set is a map with a dummy value.
set/set.go:4
TypeAlias
Sink
Sink is a pipe that does not return meaningful values.
stream/pipe.go:13
Struct
StepResult
StepResult[A] represents the result of a single step in the step machine. It might be one of - empty, new value, or finished. The step result also ret
stream/stream.go:19
TypeAlias
Stream
Stream is modelled as a function that performs a single step in the state machine.
stream/stream.go:14
Struct
StreamEvent
Fields should be checked in order - If Error == nil, If !IsFinished, then Value
stream/stream_event.go:6
Struct
Unit
Unit is a type that has only a single value.
fun/unit.go:4
Struct
channelController
stream/pool.go:69
Struct
executionContextImpl
io/execution_context.go:27
Struct
failedFiberImpl
io/fiber.go:109
Struct
fiberImpl
if result is already available, there is no need to use callbacks channel. The result will be immediately delivered.
io/fiber.go:32