blob: 81919c4ce41e5fb9bf3131e912e456b555b6c62d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
#pragma once
#include <basis/seadTypes.h>
#include <prim/seadRuntimeTypeInfo.h>
namespace ksys {
class Message;
class MessageTransceiverBase;
class MessageQueue;
struct MesTransceiverId;
class IMessageBrokerRegister {
public:
struct IForEachContext {
virtual ~IForEachContext() = default;
virtual void process(const MesTransceiverId& id) = 0;
};
virtual ~IMessageBrokerRegister() = default;
virtual bool registerTransceiver(const MesTransceiverId& id) = 0;
virtual void deregisterTransceiver(const MesTransceiverId& id) = 0;
virtual void forEachRegistered(IForEachContext& context) = 0;
virtual void setId(const u32& id) = 0;
virtual const u32& getId() const = 0;
virtual int countTransceivers() const = 0;
};
class IMessageBroker {
public:
class SetIdArg {
SEAD_RTTI_BASE(SetIdArg)
public:
SetIdArg() = default;
explicit SetIdArg(u32 id) { setId(id); }
virtual ~SetIdArg() = default;
u32 getId() const { return mId; }
void setId(u32 id) { mId = id; }
private:
u32 mId{};
};
IMessageBroker();
virtual ~IMessageBroker();
virtual void setId(const SetIdArg& arg) = 0;
virtual IMessageBrokerRegister* getRegister() = 0;
bool registerTransceiver(const MessageTransceiverBase& transceiver);
void deregisterTransceiver(const MessageTransceiverBase& transceiver);
int countTransceivers();
};
} // namespace ksys
|
