message.hpp 1.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. /**
  2. * Copyright (c) 2019 Paul-Louis Ageneau
  3. *
  4. * This library is free software; you can redistribute it and/or
  5. * modify it under the terms of the GNU Lesser General Public
  6. * License as published by the Free Software Foundation; either
  7. * version 2.1 of the License, or (at your option) any later version.
  8. *
  9. * This library is distributed in the hope that it will be useful,
  10. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  12. * Lesser General Public License for more details.
  13. *
  14. * You should have received a copy of the GNU Lesser General Public
  15. * License along with this library; if not, write to the Free Software
  16. * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  17. */
  18. #ifndef RTC_MESSAGE_H
  19. #define RTC_MESSAGE_H
  20. #include "include.hpp"
  21. #include "reliability.hpp"
  22. #include <functional>
  23. #include <memory>
  24. namespace rtc {
  25. struct Message : binary {
  26. enum Type { Binary, String, Control };
  27. template <typename Iterator>
  28. Message(Iterator begin_, Iterator end_, Type type_ = Binary, unsigned int stream_ = 0,
  29. std::shared_ptr<Reliability> reliability_ = nullptr)
  30. : binary(begin_, end_), type(type_), stream(stream_), reliability(reliability_) {}
  31. Type type;
  32. unsigned int stream;
  33. std::shared_ptr<Reliability> reliability;
  34. };
  35. using message_ptr = std::shared_ptr<const Message>;
  36. using message_callback = std::function<void(message_ptr message)>;
  37. template <typename Iterator>
  38. message_ptr make_message(Iterator begin, Iterator end, Message::Type type = Message::Binary,
  39. unsigned int stream = 0,
  40. std::shared_ptr<Reliability> reliability = nullptr) {
  41. return std::make_shared<Message>(begin, end, type, stream, reliability);
  42. }
  43. } // namespace rtc
  44. #endif