You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@celix.apache.org by pn...@apache.org on 2021/10/07 21:24:11 UTC
[celix] branch master updated (7c785c5 -> ae90ebb)
This is an automated email from the ASF dual-hosted git repository.
pnoltes pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/celix.git.
from 7c785c5 Merge pull request #370 from apache/feature/robust_promise_fail_and_resolve
new 7913540 Creating empty placeholder celix::pushstreams
new ab3a938 My first pushstream
new f2aae75 Adding asciidoc with plantuml
new debe6a5 Adding asciidoc with plantuml
new 20f2299 Adding filtering
new cba03b1 async public with executor
new b326eed Allowing multiple streams on one source
new ebcbe3f First implementation of proper closing
new a357fc4 small improvements
new 7f551d4 Adding up/down stream concept
new 69de083 Reenable stream end
new ffca583 Reenable reference interface
new b7f94d4 cleanup
new 78b38b8 adding PushStream::split(...)
new 1d46e70 Doc Update
new c1396fc Adding some tests
new d49c399 Adding synchronousSource
new 9d6cd51 Restore PushEventConsumer
new afd3b2e adding map member
new 92b884f tests free of mem leaks
new db3227e close flows
new b7a7cfc Correct closing
new a91311d adding additional test
new 3b92515 design update
new dc77418 cleanup
new 547dd1e split of event and evendata types
new 6a9f648 Enable of error flows
new 40d9709 Initial version of BufferedStream
new 2edaa47 moving ownership to user
new 75a7500 extended testing
new 484c312 Some cleanup
new 043902c file restucture
new 5f58a9f all code to implementation section
new fcc98ea adding additional tests
new a18157b update adoc
new ce7cdc7 enable split test
new 00d4f2a Merge branch 'apache:master' into feature/pushstream
new 0cefb0d Merge branch 'apache:master' into feature/pushstream
new de3a5a5 Review rework
new ae90ebb Merge pull request #363 from stegemr/feature/pushstream
The 2560 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.gitignore | 2 +
.../doc/async_remote_admin.adoc | 19 +
libs/CMakeLists.txt | 1 +
libs/pushstreams/CMakeLists.txt | 42 ++
libs/pushstreams/README.md | 23 +
.../pushstreams/api/celix/IAutoCloseable.h | 17 +-
.../api/celix/IPushEventConsumer.h} | 16 +-
.../api/celix/IPushEventSource.h} | 12 +-
.../api/celix/IllegalStateException.h} | 16 +-
libs/pushstreams/api/celix/PushEvent.h | 142 +++++
libs/pushstreams/api/celix/PushStream.h | 251 ++++++++
libs/pushstreams/api/celix/PushStreamProvider.h | 98 ++++
libs/pushstreams/api/celix/SimplePushEventSource.h | 69 +++
.../api/celix/SynchronousPushEventSource.h | 62 ++
.../api/celix/impl/AbstractPushEventSource.h | 132 +++++
.../api/celix/impl/BufferedPushStream.h | 106 ++++
.../api/celix/impl/IntermediatePushStream.h | 60 ++
.../pushstreams/api/celix/impl/PushEventConsumer.h | 62 ++
.../api/celix/impl/StreamPushEventConsumer.h | 66 +++
.../api/celix/impl/UnbufferedPushStream.h | 69 +++
libs/pushstreams/docs/pushstreams.adoc | 159 +++++
.../pushstreams}/gtest/CMakeLists.txt | 13 +-
libs/pushstreams/gtest/src/PushStreamTestSuite.cc | 653 +++++++++++++++++++++
.../pushstreams/src/PushStreamExamples.cc | 11 +-
24 files changed, 2060 insertions(+), 41 deletions(-)
create mode 100644 libs/pushstreams/CMakeLists.txt
create mode 100644 libs/pushstreams/README.md
copy bundles/pubsub/pubsub_protocol/pubsub_protocol_wire_v1/gtest/src/main.cc => libs/pushstreams/api/celix/IAutoCloseable.h (82%)
copy libs/{promises/api/celix/PromiseIllegalStateException.h => pushstreams/api/celix/IPushEventConsumer.h} (74%)
copy libs/{promises/api/celix/PromiseIllegalStateException.h => pushstreams/api/celix/IPushEventSource.h} (78%)
copy libs/{promises/api/celix/PromiseInvocationException.h => pushstreams/api/celix/IllegalStateException.h} (63%)
create mode 100644 libs/pushstreams/api/celix/PushEvent.h
create mode 100644 libs/pushstreams/api/celix/PushStream.h
create mode 100644 libs/pushstreams/api/celix/PushStreamProvider.h
create mode 100644 libs/pushstreams/api/celix/SimplePushEventSource.h
create mode 100644 libs/pushstreams/api/celix/SynchronousPushEventSource.h
create mode 100644 libs/pushstreams/api/celix/impl/AbstractPushEventSource.h
create mode 100644 libs/pushstreams/api/celix/impl/BufferedPushStream.h
create mode 100644 libs/pushstreams/api/celix/impl/IntermediatePushStream.h
create mode 100644 libs/pushstreams/api/celix/impl/PushEventConsumer.h
create mode 100644 libs/pushstreams/api/celix/impl/StreamPushEventConsumer.h
create mode 100644 libs/pushstreams/api/celix/impl/UnbufferedPushStream.h
create mode 100644 libs/pushstreams/docs/pushstreams.adoc
copy {bundles/logging/log_helper => libs/pushstreams}/gtest/CMakeLists.txt (67%)
create mode 100644 libs/pushstreams/gtest/src/PushStreamTestSuite.cc
copy bundles/pubsub/pubsub_protocol/pubsub_protocol_wire_v2/gtest/src/main.cc => libs/pushstreams/src/PushStreamExamples.cc (84%)