Bläddra i källkod

Exposed send(data, size) on Channel

Paul-Louis Ageneau 4 år sedan
förälder
incheckning
ea87e5ae09
5 ändrade filer med 8 tillägg och 2 borttagningar
  1. 1 0
      include/rtc/channel.hpp
  2. 1 1
      include/rtc/datachannel.hpp
  3. 1 1
      include/rtc/track.hpp
  4. 1 0
      include/rtc/websocket.hpp
  5. 4 0
      src/websocket.cpp

+ 1 - 0
include/rtc/channel.hpp

@@ -35,6 +35,7 @@ public:
 
 	virtual void close() = 0;
 	virtual bool send(message_variant data) = 0; // returns false if buffered
+	virtual bool send(const byte *data, size_t size) = 0;
 
 	virtual bool isOpen() const = 0;
 	virtual bool isClosed() const = 0;

+ 1 - 1
include/rtc/datachannel.hpp

@@ -50,7 +50,7 @@ public:
 
 	void close(void) override;
 	bool send(message_variant data) override;
-	bool send(const byte *data, size_t size);
+	bool send(const byte *data, size_t size) override;
 	template <typename Buffer> bool sendBuffer(const Buffer &buf);
 	template <typename Iterator> bool sendBuffer(Iterator first, Iterator last);
 

+ 1 - 1
include/rtc/track.hpp

@@ -47,7 +47,7 @@ public:
 
 	void close(void) override;
 	bool send(message_variant data) override;
-	bool send(const byte *data, size_t size);
+	bool send(const byte *data, size_t size) override;
 
 	bool isOpen(void) const override;
 	bool isClosed(void) const override;

+ 1 - 0
include/rtc/websocket.hpp

@@ -59,6 +59,7 @@ public:
 	void open(const string &url);
 	void close() override;
 	bool send(const message_variant data) override;
+	bool send(const byte *data, size_t size) override;
 
 	bool isOpen() const override;
 	bool isClosed() const override;

+ 4 - 0
src/websocket.cpp

@@ -118,6 +118,10 @@ void WebSocket::remoteClose() {
 
 bool WebSocket::send(message_variant data) { return outgoing(make_message(std::move(data))); }
 
+bool WebSocket::send(const byte *data, size_t size) {
+	return outgoing(make_message(data, data + size));
+}
+
 bool WebSocket::isOpen() const { return mState == State::Open; }
 
 bool WebSocket::isClosed() const { return mState == State::Closed; }