Added sendBinary method for WebSocket class.

source/vibe/http/websockets.d

@@ -119,12 +119,14 @@ struct Frame {
 class OutgoingWebSocketMessage : OutputStream {
 	private {
 		Stream m_conn;
+		FrameOpcode m_frameOpcode;
 		Appender!(ubyte[]) m_buffer;
 	}
 
-	this( Stream conn ) {
+	this( Stream conn, FrameOpcode frameOpcode ) {
 		assert(conn !is null);
 		m_conn = conn;
+		m_frameOpcode = frameOpcode;
 	}
 
 	void write(in ubyte[] bytes, bool do_flush = true) {
@@ -133,7 +135,7 @@ class OutgoingWebSocketMessage : OutputStream {
 	}
 	void flush() {
 		Frame frame;
-		frame.opcode = FrameOpcode.Text;
+		frame.opcode = m_frameOpcode;
 		frame.fin = true;
 		frame.payload = m_buffer.data;
 		frame.writeFrame(m_conn);
@@ -142,9 +144,9 @@ class OutgoingWebSocketMessage : OutputStream {
 	void finalize() {
 		Frame frame;
 		frame.fin = true;
-		frame.opcode = FrameOpcode.Text;
+		frame.opcode = m_frameOpcode;
 		frame.payload = m_buffer.data;
-		frame.writeFrame(m_conn);		
+		frame.writeFrame(m_conn);
 		m_buffer.clear();
 	}
 	void write(InputStream stream, ulong nbytes = 0, bool do_flush = true) {
@@ -231,8 +233,12 @@ class WebSocket {
 	{
 		send( (message) { message.write(data); });
 	}
-	void send(void delegate(OutgoingWebSocketMessage) sender) {
-		auto message = new OutgoingWebSocketMessage(m_conn);
+	void sendBinary(ubyte[] data)
+	{
+		send( (message) { message.write(data); }, FrameOpcode.Binary );
+	}
+	void send(void delegate(OutgoingWebSocketMessage) sender, FrameOpcode frameOpcode = FrameOpcode.Text) {
+		auto message = new OutgoingWebSocketMessage(m_conn, frameOpcode);
 		sender(message);
 	}
 
@@ -291,4 +297,4 @@ HttpServerRequestDelegate handleWebSockets(void delegate(WebSocket) onHandshake)
 		onHandshake(socket);
 	}
 	return &callback;
-}
+}