MCPcopy Create free account

hub / github.com/Primetalk/goio / types & classes

Types & classes31 in github.com/Primetalk/goio

InterfaceAny
fun/cast.go:3
StructBackpressureChannel
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
FuncTypeCallback
Callback[A] is a function that takes A and error. A is only valid if error is nil.
io/async.go:4
StructClosable
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
InterfaceClosableIO
ClosableIO is a simple resource that implements Close method.
resource/closable_io.go:6
FuncTypeCollector
Collector reads the stream and produces some value.
stream/execution.go:14
FuncTypeConsumer
Consumer can receive an instance of A and perform some operation on it.
io/consumer.go:4
FuncTypeContinuation
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
StructEither
Either is a simple data structure that can have either left value or right value.
either/either.go:6
InterfaceExecutionContext
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
InterfaceFiber
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
StructGoResult
GoResult[A] is a data structure that represents the Go-style result of a function that could fail.
io/goresult.go:5
TypeAliasIO
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
InterfaceNumber
Number is a generic number interface that covers all Go number types.
fun/numbers.go:6
StructOption
Option[A] can represent a value or an absent value of type A.
option/option.go:7
StructPair
Pair is a data structure that has two values.
fun/pair.go:4
FuncTypePipe
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
FuncTypePredicate
Predicate is a function with a boolean result type.
fun/predicate.go:4
TypeAliasResource
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
StructResultOrContinuation
ResultOrContinuation is either a final result (value or error) or another continuation.
io/continuation.go:15
FuncTypeRunnable
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
TypeAliasSet
Set is a map with a dummy value.
set/set.go:4
TypeAliasSink
Sink is a pipe that does not return meaningful values.
stream/pipe.go:13
StructStepResult
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
TypeAliasStream
Stream is modelled as a function that performs a single step in the state machine.
stream/stream.go:14
StructStreamEvent
Fields should be checked in order - If Error == nil, If !IsFinished, then Value
stream/stream_event.go:6
StructUnit
Unit is a type that has only a single value.
fun/unit.go:4
StructchannelController
stream/pool.go:69
StructexecutionContextImpl
io/execution_context.go:27
StructfailedFiberImpl
io/fiber.go:109
StructfiberImpl
if result is already available, there is no need to use callbacks channel. The result will be immediately delivered.
io/fiber.go:32