Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/andreiavrammsd/cpp-channel
/ functions
Functions
55 in github.com/andreiavrammsd/cpp-channel
⨍
Functions
55
◇
Types & classes
21
↓ 18 callers
Method
close
* @brief Closes the channel, no longer accepting new elements. */
include/msd/channel.hpp:234
↓ 15 callers
Method
size
* @brief Returns the current size of the channel. * * @return The number of elements in the channel. */
include/msd/channel.hpp:213
↓ 12 callers
Method
write
include/msd/channel.hpp:165
↓ 11 callers
Method
begin
* @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 callers
Method
push_back
include/msd/storage.hpp:39
↓ 10 callers
Method
end
* @brief Returns an iterator representing the end of the channel. * * @return A blocking iterator representing the end condition. */
include/msd/channel.hpp:279
↓ 7 callers
Function
back_inserter
include/msd/blocking_iterator.hpp:189
↓ 7 callers
Method
read
* @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 callers
Method
empty
* @brief Checks if the channel is empty. * * @return true If the channel contains no elements. * @return false Otherwise. */
include/msd/channel.hpp:225
↓ 5 callers
Method
pop_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 callers
Method
closed
* @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 callers
Method
drained
* @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 callers
Method
get_value
examples/move.cpp:16
↓ 2 callers
Function
transform
Read data from the incoming channel, process it, then send it on the outgoing channel
examples/cmake-project/src/main.cpp:25
↓ 1 callers
Method
acquire
examples/semaphore.cpp:14
↓ 1 callers
Function
add
Time-consuming operation for each input value
examples/cmake-project/src/main.cpp:18
↓ 1 callers
Method
get_value
tests/channel_test.cpp:368
↓ 1 callers
Method
release
examples/semaphore.cpp:16
↓ 1 callers
Function
simulate_heavy_computation
examples/semaphore.cpp:24
Method
MovableOnly
tests/channel_test.cpp:337
Function
TEST
tests/channel_test.cpp:17
Function
TEST
tests/blocking_iterator_test.cpp:11
Function
TYPED_TEST
tests/storage_test.cpp:14
Function
bench_dynamic_storage
benchmarks/channel_benchmark.cpp:92
Function
bench_static_storage
benchmarks/channel_benchmark.cpp:116
Method
blocking_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
Method
blocking_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
Method
channel
include/msd/channel.hpp:112
Method
closed_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
Method
data
examples/move.cpp:13
Function
get_incoming
Continuously write input data on the incoming channel
examples/cmake-project/src/main.cpp:9
Function
main
examples/semaphore.cpp:34
Function
main
examples/concurrent_map_filter.cpp:17
Function
main
examples/move.cpp:63
Function
main
examples/streaming.cpp:12
Function
main
examples/cmake-project/src/main.cpp:41
Function
main
examples/bazel-project/src/main.cpp:6
Method
make
benchmarks/channel_benchmark.cpp:80
Method
make
benchmarks/channel_benchmark.cpp:88
Method
operator!=
* @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
Method
operator*
* @brief Returns the latest element retrieved from the channel. * * @return A const reference to the element. */
include/msd/blocking_iterator.hpp:79
Method
operator++
* @brief Not applicable (handled by operator=). * * @return The iterator itself. */
include/msd/blocking_iterator.hpp:175
Method
pop_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
Method
pop_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
Method
push_back
include/msd/storage.hpp:91
Method
push_back
include/msd/storage.hpp:146
Method
queue_storage
* @brief Constructs the queue storage (parameter ignored, required for interface compatibility). * * @warning Do not construct manually. Thi
include/msd/storage.hpp:30
Method
semaphore
examples/semaphore.cpp:12
Method
vector_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
Method
wait_before_read
include/msd/channel.hpp:294
Method
wait_before_write
include/msd/channel.hpp:299
Function
write_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