Commit 35e01dcc authored by tqcq's avatar tqcq
Browse files

feat fix event_bus test

parent 8bd904bf
Loading
Loading
Loading
Loading
+5 −2
Original line number Diff line number Diff line
@@ -97,7 +97,10 @@ private:

class EventBus {
public:
   template<typename mt_policy = sigslot::multi_threaded_local>
    using MultiThreadedLocal  = sigslot::multi_threaded_local;
    using MultiThreadedGlobal = sigslot::multi_threaded_global;

    template<typename mt_policy = MultiThreadedLocal>
    using Subscriber = sigslot::has_slots<mt_policy>;

    EventBus() = default;
+1 −1
Original line number Diff line number Diff line
@@ -13,7 +13,7 @@ struct AtomicEvent {
    std::atomic<int> &data;
};

struct Subscriber : public sled::EventBus::Subscriber {
struct Subscriber : public sled::EventBus::Subscriber<> {
    void OnEvent(Event event) { (*event.data)++; }

    void OnAtomicnEvent(AtomicEvent event) { event.data.fetch_add(1); }
+1 −1
Original line number Diff line number Diff line
@@ -26,7 +26,7 @@ struct Event2 {
    std::string str;
};

struct Subscriber : public sled::EventBus::Subscriber {
struct Subscriber : public sled::EventBus::Subscriber<> {
    void OnEvent1(Event1 event) { a += event.a; }

    void OnEvent2(Event2 event) { str += event.str; }
+2 −2
Original line number Diff line number Diff line
@@ -167,7 +167,7 @@ Base64::Decode(const uint8_t *ptr, size_t len)
            break;
        } else {
            // invalid character
            return make_status_or<std::string>(StatusCode::kInvalidArgument,
            return MakeStatusOr<std::string>(StatusCode::kInvalidArgument,
                                             fmt::format("Invalid character [{}] at index [{}]", (char) c, index));
        }
        ++index;