diff --git a/include/pulsar/c/result.h b/include/pulsar/c/result.h index a95d1e58..ab30ab22 100644 --- a/include/pulsar/c/result.h +++ b/include/pulsar/c/result.h @@ -92,6 +92,7 @@ typedef enum pulsar_result_MemoryBufferIsFull, /// Client-wide memory limit has been reached pulsar_result_Interrupted, /// Interrupted while waiting to dequeue + pulsar_result_Disconnected, /// Client connection has been disconnected } pulsar_result; // Return string representation of result code diff --git a/tests/c/c_MessageTest.cc b/tests/c/c_MessageTest.cc index 7a2ee506..7b56512e 100644 --- a/tests/c/c_MessageTest.cc +++ b/tests/c/c_MessageTest.cc @@ -18,7 +18,9 @@ */ #include #include +#include #include +#include #include "../PulsarFriend.h" @@ -48,3 +50,8 @@ TEST(c_MessageTest, ReplicationMetadataAccessors) { pulsar_message_free(message); } + +TEST(c_ResultTest, DisconnectedResultMatchesCppResult) { + ASSERT_EQ(static_cast(pulsar::ResultDisconnected), static_cast(pulsar_result_Disconnected)); + ASSERT_STREQ("ResultDisconnected", pulsar_result_str(pulsar_result_Disconnected)); +}