/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/pubsub/ |
H A D | ack_handler.cc | 23 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 D | ack_handler.h | 48 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 D | ack_handler_test.cc | 31 { 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 D | subscriber_test.cc | 40 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 D | ack_handler.cc | 23 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 D | ack_handler.h | 36 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 D | ack_handler_test.cc | 31 { 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 D | subscriber_test.cc | 42 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | message.go | 21 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 D | ack_handler.h | 21 class INVALIDATION_EXPORT AckHandler { 23 AckHandler() = default; 24 virtual ~AckHandler() = default;
|