MCPcopy Create free account

hub / github.com/Primetalk/goio / functions

Functions426 in github.com/Primetalk/goio

⨍ Functions 426◇ Types & classes 31
FunctionStartInExecutionContext
StartInExecutionContext executes the given task in the provided ExecutionContext It'll establish a channel with callbacks, so that any number of liste
io/fiber.go:68
FunctionStartInGoRoutineAndWaitForResult
StartInGoRoutineAndWaitForResult - not very useful function. While it executes the IO in the go routine, the current thread is blocked.
io/async.go:27
FunctionStringLen
(s string)
option/option_test.go:11
FunctionTestBracket
(t *testing.T)
transaction/bracket_test.go:13
FunctionTestBracketRollback
(t *testing.T)
transaction/bracket_test.go:27
FunctionTestCast
(t *testing.T)
fun/cast_test.go:10
FunctionTestChannelResource
(t *testing.T)
resource/resource_test.go:63
FunctionTestChunks
(t *testing.T)
stream/stream_test.go:80
FunctionTestChunksResize
(t *testing.T)
stream/chunks_test.go:10
FunctionTestConcatPipes
(t *testing.T)
stream/pipe_test.go:10
FunctionTestCount
(t *testing.T)
slice/slice_test.go:81
FunctionTestDrainAll
(t *testing.T)
stream/stream_test.go:37
FunctionTestEither
(t *testing.T)
either/either_test.go:12
FunctionTestEqualTo
(t *testing.T)
fun/predicate_test.go:10
FunctionTestErr
(t *testing.T)
io/io_test.go:28
FunctionTestExecutionContext
(t *testing.T)
stream/pool_test.go:36
FunctionTestFailedDataStreamThroughEC
(t *testing.T)
stream/pool_test.go:66
FunctionTestFailedDataStreamThroughECUnord
(t *testing.T)
stream/pool_test.go:97
FunctionTestFailedResource
(t *testing.T)
resource/resource_test.go:53
FunctionTestFailedStream
(t *testing.T)
stream/stream_test.go:121
FunctionTestFailedStreamThroughEC
(t *testing.T)
stream/pool_test.go:59
FunctionTestFanOutFailedStream
(t *testing.T)
stream/backpressure_channels_test.go:33
FunctionTestFanOutFiniteSourceNoFailure
(t *testing.T)
stream/backpressure_channels_test.go:28
FunctionTestFanOutToAllShortStream
(t *testing.T)
stream/backpressure_channels_test.go:43
FunctionTestFanOutToFailedStream
(t *testing.T)
stream/backpressure_channels_test.go:53
FunctionTestFanOutToShortStream
(t *testing.T)
stream/backpressure_channels_test.go:38
FunctionTestFanOutToSingleShortStream
(t *testing.T)
stream/backpressure_channels_test.go:48
FunctionTestFile
(t *testing.T)
text/file_test.go:54
FunctionTestFilter
(t *testing.T)
slice/slice_test.go:27
FunctionTestFilter
(t *testing.T)
set/set_test.go:21
FunctionTestFilter
(t *testing.T)
option/option_test.go:29
FunctionTestFinally
(t *testing.T)
io/io_test.go:38
FunctionTestFlatMapPipe
(t *testing.T)
stream/stream_test.go:62
FunctionTestFlatten
(t *testing.T)
slice/slice_test.go:44
FunctionTestFlatten
(t *testing.T)
option/option_test.go:39
FunctionTestFoldLeftEval
(t *testing.T)
stream/stream_test.go:135
FunctionTestForEach
(t *testing.T)
slice/slice_test.go:101
FunctionTestForEach
(t *testing.T)
stream/execution_test.go:12
FunctionTestForEach
(t *testing.T)
option/option_test.go:43
FunctionTestFun
(t *testing.T)
fun/fun_test.go:14
FunctionTestGenerate
(t *testing.T)
stream/stream_test.go:21
FunctionTestGroupBy
(t *testing.T)
slice/slice_test.go:52
FunctionTestGroupBy
(t *testing.T)
stream/stream_test.go:87
FunctionTestGroupByEval
(t *testing.T)
stream/stream_test.go:100
FunctionTestGroupByEvalFailed
(t *testing.T)
stream/stream_test.go:113
FunctionTestGroupByMapCount
(t *testing.T)
slice/slice_test.go:75
FunctionTestGrouped
(t *testing.T)
slice/slice_test.go:70
FunctionTestHeadAndTail
(t *testing.T)
slice/slice_test.go:161
FunctionTestHeadAndTail
(t *testing.T)
stream/execution_test.go:37
FunctionTestHeadTail
(t *testing.T)
slice/slice_test.go:144
FunctionTestHeadTailPanic
(t *testing.T)
slice/slice_test.go:151
FunctionTestIO
(t *testing.T)
io/io_test.go:11
FunctionTestIgnore
(t *testing.T)
io/io_test.go:62
FunctionTestIndexOf
(t *testing.T)
slice/slice_test.go:109
FunctionTestIntersection
(t *testing.T)
slice/slice_test.go:130
FunctionTestIsDefined
(t *testing.T)
option/option_test.go:34
FunctionTestJoinWithTimeout
(t *testing.T)
io/fiber_test.go:10
FunctionTestKeys
(t *testing.T)
maps/maps_test.go:10
FunctionTestLiftFunc
(t *testing.T)
io/io_test.go:23
FunctionTestMap
(t *testing.T)
option/option_test.go:18
FunctionTestMapKeys
(t *testing.T)
maps/maps_test.go:32
FunctionTestMapSlice
(t *testing.T)
io/io_slice_test.go:11
FunctionTestMemoize
(t *testing.T)
fun/memoize_test.go:10
FunctionTestMemoize
(t *testing.T)
io/memoize_test.go:10
FunctionTestMerge
(t *testing.T)
maps/maps_test.go:15
FunctionTestMin
(t *testing.T)
fun/numbers_test.go:10
FunctionTestNats
(t *testing.T)
stream/common_test.go:43
FunctionTestNormalFinish
(t *testing.T)
stream/stream_event_test.go:10
FunctionTestNotify
(t *testing.T)
io/time_test.go:21
FunctionTestPair
(t *testing.T)
fun/fun_test.go:22
FunctionTestPairBoth
(t *testing.T)
fun/pair_test.go:10
FunctionTestPairParallelAndRunAlso
(t *testing.T)
io/parallel_test.go:46
FunctionTestPairSequentially
(t *testing.T)
io/parallel_test.go:60
FunctionTestPairSwap
(t *testing.T)
fun/pair_test.go:16
FunctionTestPanicRecovery
(t *testing.T)
fun/errors_test.go:12
FunctionTestParallel
(t *testing.T)
io/parallel_test.go:20
FunctionTestParallelBound
(t *testing.T)
io/parallel_test.go:31
FunctionTestParallelBound
(t *testing.T)
resource/bounded_ec_test.go:21
FunctionTestPartition
(t *testing.T)
stream/execution_test.go:24
FunctionTestPool
(t *testing.T)
stream/pool_test.go:14
FunctionTestRange
(t *testing.T)
slice/numbers_test.go:10
FunctionTestReduce
(t *testing.T)
slice/slice_test.go:86
FunctionTestRemove
(t *testing.T)
slice/slice_test.go:123
FunctionTestResource
(t *testing.T)
resource/resource_test.go:14
FunctionTestResourceFail
(t *testing.T)
resource/resource_test.go:34
FunctionTestResourceInResource
(t *testing.T)
resource/resource_test.go:74
FunctionTestRetry
(t *testing.T)
io/error_handling_test.go:27
FunctionTestRetryS
(t *testing.T)
io/error_handling_test.go:11
FunctionTestReverse
(t *testing.T)
slice/slice_test.go:114
FunctionTestSendingDataThroughChannel
(t *testing.T)
stream/channel_test.go:12
FunctionTestSequence
(t *testing.T)
io/io_test.go:50
FunctionTestSet
(t *testing.T)
set/set_test.go:13
FunctionTestSideEval
(t *testing.T)
stream/stream_test.go:189
FunctionTestSliding
(t *testing.T)
slice/slice_test.go:63
FunctionTestStateFlatMap
(t *testing.T)
stream/stream_test.go:51
FunctionTestStateFlatMapWithFinishAndFailureHandling
(t *testing.T)
stream/stream_test.go:140
FunctionTestStateFlatMapWithFinishAndFailureHandling2
(t *testing.T)
stream/stream_test.go:158
FunctionTestStream
(t *testing.T)
stream/stream_test.go:12
FunctionTestStreamConversion
(t *testing.T)
stream/channel_test.go:33
FunctionTestStreamEventOfFailedStream
(t *testing.T)
stream/stream_event_test.go:15
← previousnext →301–400 of 426, ranked by callers