diff options
| author | Oskari Timperi <oskari.timperi@iki.fi> | 2017-03-06 21:31:07 +0200 |
|---|---|---|
| committer | Oskari Timperi <oskari.timperi@iki.fi> | 2017-03-06 21:31:07 +0200 |
| commit | a062d934aef40829d9559a8ca83147ea4c44108e (patch) | |
| tree | 6ee1f9eb3208bea65365e63d039ad27c40111c6f /test/interop/testclient.h | |
| parent | e9958e8a0f5aa5fbe0a4a03be42b8bf640add6f7 (diff) | |
| download | mqtt-a062d934aef40829d9559a8ca83147ea4c44108e.tar.gz mqtt-a062d934aef40829d9559a8ca83147ea4c44108e.zip | |
Massive refactoring of the internals
Diffstat (limited to 'test/interop/testclient.h')
| -rw-r--r-- | test/interop/testclient.h | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/test/interop/testclient.h b/test/interop/testclient.h index 2aa229b..3665f5e 100644 --- a/test/interop/testclient.h +++ b/test/interop/testclient.h @@ -21,6 +21,8 @@ typedef struct TestClient TestClient; struct TestClient { + const char *clientId; + MqttClient *client; /* OnConnect */ @@ -37,6 +39,9 @@ struct TestClient /* OnMessage */ SIMPLEQ_HEAD(messages, Message) messages; + + /* OnUnsubscribe */ + int unsubId; }; Message *MessageNew(const char *topic, const void *data, size_t size, @@ -65,4 +70,6 @@ int TestClientMessageCount(TestClient *client); int TestClientWait(TestClient *client, int timeout); +int TestClientUnsubscribe(TestClient *client, const char *topic); + #endif |