Home
last modified time | relevance | path

Searched refs:AckHandler (Results 1 – 25 of 57) sorted by relevance

123

/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/pubsub/
H A Dack_handler.cc23 static_assert(!std::is_copy_assignable<AckHandler>::value,
25 static_assert(!std::is_copy_constructible<AckHandler>::value,
27 static_assert(std::is_move_assignable<AckHandler>::value,
29 static_assert(std::is_move_constructible<AckHandler>::value,
32 AckHandler::~AckHandler() { in ~AckHandler()
36 AckHandler::Impl::~Impl() = default;
H A Dack_handler.h48 class AckHandler {
50 ~AckHandler();
52 AckHandler(AckHandler&&) noexcept = default;
53 AckHandler& operator=(AckHandler&&) noexcept = default;
104 explicit AckHandler(std::unique_ptr<Impl> impl) : impl_(std::move(impl)) {} in AckHandler() function
H A Dack_handler_test.cc31 { AckHandler handler(std::move(mock)); } in TEST()
38 AckHandler handler(std::move(mock)); in TEST()
39 AckHandler moved = std::move(handler); in TEST()
48 AckHandler handler(std::move(mock)); in TEST()
55 AckHandler handler(std::move(mock)); in TEST()
62 AckHandler handler(std::move(mock)); in TEST()
H A Dsubscriber_test.cc40 AckHandler(std::move(ack))); in TEST()
47 AckHandler(std::move(ack))); in TEST()
55 .Subscribe([&](Message const& m, AckHandler h) { in TEST()
76 auto handler = [&](Message const&, AckHandler const&) {}; in TEST()
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/
H A Dack_handler.cc23 static_assert(!std::is_copy_assignable<AckHandler>::value,
25 static_assert(!std::is_copy_constructible<AckHandler>::value,
27 static_assert(std::is_move_assignable<AckHandler>::value,
29 static_assert(std::is_move_constructible<AckHandler>::value,
32 AckHandler::~AckHandler() { in ~AckHandler()
36 AckHandler::Impl::~Impl() = default;
H A Dack_handler.h36 class AckHandler {
38 ~AckHandler();
40 AckHandler(AckHandler&&) noexcept = default;
41 AckHandler& operator=(AckHandler&&) noexcept = default;
79 explicit AckHandler(std::unique_ptr<Impl> impl) : impl_(std::move(impl)) {} in AckHandler() function
H A Dack_handler_test.cc31 { AckHandler handler(std::move(mock)); } in TEST()
38 AckHandler handler(std::move(mock)); in TEST()
39 AckHandler moved = std::move(handler); in TEST()
48 AckHandler handler(std::move(mock)); in TEST()
56 AckHandler handler(std::move(mock)); in TEST()
63 AckHandler handler(std::move(mock)); in TEST()
70 AckHandler handler(std::move(mock)); in TEST()
H A Dsubscriber_test.cc42 AckHandler(std::move(ack))); in TEST()
49 AckHandler(std::move(ack))); in TEST()
58 [&](Message const& m, AckHandler h) { in TEST()
81 auto handler = [&](Message const&, AckHandler const&) {}; in TEST()
/dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/sysutils/restic/google-cloud-go-storage-v1.16.0/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/databases/litestream/litestream-0.3.6/vendor/cloud.google.com/go/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/www/tusd/tusd-1.8.0/vendor/cloud.google.com/go/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/www/tusd/google-cloud-go-storage-v1.18.2/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/databases/litestream/google-cloud-go-storage-v1.15.0/internal/pubsub/
H A Dmessage.go21 type AckHandler interface {
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message {
95 func MessageAckHandler(m *Message) AckHandler {
/dports/www/grafana8/google-cloud-go-storage-v1.14.0/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/sysutils/terraform/terraform-1.0.11/vendor/cloud.google.com/go/internal/pubsub/
H A Dmessage.go21 type AckHandler interface { interface
63 ackh AckHandler
90 func NewMessage(ackh AckHandler) *Message { argument
95 func MessageAckHandler(m *Message) AckHandler {
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/invalidation/public/
H A Dack_handler.h21 class INVALIDATION_EXPORT AckHandler {
23 AckHandler() = default;
24 virtual ~AckHandler() = default;

123