MCPcopy Create free account

hub / github.com/andreiavrammsd/cpp-channel / functions

Functions55 in github.com/andreiavrammsd/cpp-channel

↓ 18 callersMethodclose
* @brief Closes the channel, no longer accepting new elements. */
include/msd/channel.hpp:234
↓ 15 callersMethodsize
* @brief Returns the current size of the channel. * * @return The number of elements in the channel. */
include/msd/channel.hpp:213
↓ 12 callersMethodwrite
include/msd/channel.hpp:165
↓ 11 callersMethodbegin
* @brief Returns an iterator to the beginning of the channel. * * @return A blocking iterator pointing to the start of the channel. */
include/msd/channel.hpp:272
↓ 11 callersMethodpush_back
include/msd/storage.hpp:39
↓ 10 callersMethodend
* @brief Returns an iterator representing the end of the channel. * * @return A blocking iterator representing the end condition. */
include/msd/channel.hpp:279
↓ 7 callersFunctionback_inserter
include/msd/blocking_iterator.hpp:189
↓ 7 callersMethodread
* @brief Pops an element from the channel. * * @param out Reference to the variable where the popped element will be stored. * @return
include/msd/channel.hpp:190
↓ 5 callersMethodempty
* @brief Checks if the channel is empty. * * @return true If the channel contains no elements. * @return false Otherwise. */
include/msd/channel.hpp:225
↓ 5 callersMethodpop_front
* @brief Removes the front element from the queue and moves it to the output. * * @param out Reference to the variable where the front eleme
include/msd/storage.hpp:50
↓ 3 callersMethodclosed
* @brief Checks if the channel has been closed. * * @return true If no more elements can be added to the channel. * @return false Other
include/msd/channel.hpp:249
↓ 3 callersMethoddrained
* @brief Checks if the channel has been closed and is empty. * * @return true If nothing can be read anymore from the channel. * @retur
include/msd/channel.hpp:261
↓ 2 callersMethodget_value
examples/move.cpp:16
↓ 2 callersFunctiontransform
Read data from the incoming channel, process it, then send it on the outgoing channel
examples/cmake-project/src/main.cpp:25
↓ 1 callersMethodacquire
examples/semaphore.cpp:14
↓ 1 callersFunctionadd
Time-consuming operation for each input value
examples/cmake-project/src/main.cpp:18
↓ 1 callersMethodget_value
tests/channel_test.cpp:368
↓ 1 callersMethodrelease
examples/semaphore.cpp:16
↓ 1 callersFunctionsimulate_heavy_computation
examples/semaphore.cpp:24
MethodMovableOnly
tests/channel_test.cpp:337
FunctionTEST
tests/channel_test.cpp:17
FunctionTEST
tests/blocking_iterator_test.cpp:11
FunctionTYPED_TEST
tests/storage_test.cpp:14
Functionbench_dynamic_storage
benchmarks/channel_benchmark.cpp:92
Functionbench_static_storage
benchmarks/channel_benchmark.cpp:116
Methodblocking_iterator
* @brief Constructs a blocking iterator from a channel reference. * * @param chan Reference to the channel this iterator will iterate over.
include/msd/blocking_iterator.hpp:54
Methodblocking_writer_iterator
* @brief Constructs a blocking iterator from a channel reference. * * @param chan Reference to the channel this iterator will write into.
include/msd/blocking_iterator.hpp:136
Methodchannel
include/msd/channel.hpp:112
Methodclosed_channel
* @brief Constructs the exception with an error message. * * @param msg A descriptive message explaining the cause of the error. */
include/msd/channel.hpp:30
Methoddata
examples/move.cpp:13
Functionget_incoming
Continuously write input data on the incoming channel
examples/cmake-project/src/main.cpp:9
Functionmain
examples/semaphore.cpp:34
Functionmain
examples/concurrent_map_filter.cpp:17
Functionmain
examples/move.cpp:63
Functionmain
examples/streaming.cpp:12
Functionmain
examples/cmake-project/src/main.cpp:41
Functionmain
examples/bazel-project/src/main.cpp:6
Methodmake
benchmarks/channel_benchmark.cpp:80
Methodmake
benchmarks/channel_benchmark.cpp:88
Methodoperator!=
* @brief Makes iteration continue until the channel is closed and empty. * * @param other Another blocking_iterator to compare with. *
include/msd/blocking_iterator.hpp:88
Methodoperator*
* @brief Returns the latest element retrieved from the channel. * * @return A const reference to the element. */
include/msd/blocking_iterator.hpp:79
Methodoperator++
* @brief Not applicable (handled by operator=). * * @return The iterator itself. */
include/msd/blocking_iterator.hpp:175
Methodpop_front
* @brief Removes the front element from the vector and moves it to the output. * * @param out Reference to the variable where the front elem
include/msd/storage.hpp:102
Methodpop_front
* @brief Marks the front element as removed and moves it to the output. * * @param out Reference to the variable where the front element wil
include/msd/storage.hpp:158
Methodpush_back
include/msd/storage.hpp:91
Methodpush_back
include/msd/storage.hpp:146
Methodqueue_storage
* @brief Constructs the queue storage (parameter ignored, required for interface compatibility). * * @warning Do not construct manually. Thi
include/msd/storage.hpp:30
Methodsemaphore
examples/semaphore.cpp:12
Methodvector_storage
* @brief Constructs a queue storage with a given capacity. * * @param capacity Maximum number of elements the storage can hold. * @note
include/msd/storage.hpp:82
Methodwait_before_read
include/msd/channel.hpp:294
Methodwait_before_write
include/msd/channel.hpp:299
Functionwrite_outgoing
Read result of processing from the outgoing channel and save it
examples/cmake-project/src/main.cpp:34
Method~MovableOnly
tests/channel_test.cpp:370
Method~channel
include/msd/channel.hpp:285
Method~data
examples/move.cpp:52