Introduced method sendFragmentedFrame() to send fragmented frames more

convenient.

Author: Davidiusdadi

src/main/java/org/java_websocket/WebSocket.java

@@ -6,6 +6,7 @@
 
 importorg.java_websocket.drafts.Draft;
 importorg.java_websocket.framing.Framedata;
+importorg.java_websocket.framing.Framedata.Opcode;
 
 publicinterfaceWebSocket{
 publicenumRole{
@@ -62,6 +63,21 @@ public enum READYSTATE{
 
 publicabstractvoidsendFrame( Framedataframedata );
 
+/**
+ * Allows to send continuous/fragmented frames conveniently. <br>
+ * For more into on this frame type see http://tools.ietf.org/html/rfc6455#section-5.4<br>
+ * 
+ * If the first frame you send is also the last then it is not a fragmented frame and will received via onMessage instead of onFragmented even though it was send by this method.
+ * 
+ * @param op
+ * This is only important for the first frame in the sequence. Opcode.TEXT, Opcode.BINARY are allowed.
+ * @param buffer
+ * The buffer which contains the payload. It may have no bytes remaining.
+ * @param fin
+ * true means the current frame is the last in the sequence.
+ **/
+publicabstractvoidsendFragmentedFrame( Opcodeop, ByteBufferbuffer, booleanfin );
+
 publicabstractbooleanhasBufferedData();
 
 /**

src/main/java/org/java_websocket/WebSocketImpl.java

@@ -577,6 +577,11 @@ private void send( Collection<Framedata> frames ){
  }
  }
 
+@Override
+publicvoidsendFragmentedFrame( Opcodeop, ByteBufferbuffer, booleanfin ){
+send( draft.continuousFrame( op, buffer, fin ) );
+ }
+
 @Override
 publicvoidsendFrame( Framedataframedata ){
 if( DEBUG )

src/main/java/org/java_websocket/drafts/Draft.java

@@ -12,7 +12,10 @@
 importorg.java_websocket.exceptions.InvalidHandshakeException;
 importorg.java_websocket.exceptions.LimitExedeedException;
 importorg.java_websocket.framing.CloseFrame;
+importorg.java_websocket.framing.FrameBuilder;
 importorg.java_websocket.framing.Framedata;
+importorg.java_websocket.framing.Framedata.Opcode;
+importorg.java_websocket.framing.FramedataImpl1;
 importorg.java_websocket.handshake.ClientHandshake;
 importorg.java_websocket.handshake.ClientHandshakeBuilder;
 importorg.java_websocket.handshake.HandshakeBuilder;
@@ -46,6 +49,8 @@ public enum CloseHandshakeType{
 /** In some cases the handshake will be parsed different depending on whether */
 protectedRolerole = null;
 
+protectedOpcodecontinuousFrameType = null;
+
 publicstaticByteBufferreadLine( ByteBufferbuf ){
 ByteBuffersbuf = ByteBuffer.allocate( buf.remaining() );
 byteprev = '0';
@@ -123,6 +128,34 @@ protected boolean basicAccept( Handshakedata handshakedata ){
 
 publicabstractList<Framedata> createFrames( Stringtext, booleanmask );
 
+publicList<Framedata> continuousFrame( Opcodeop, ByteBufferbuffer, booleanfin ){
+if( op != Opcode.BINARY && op != Opcode.TEXT && op != Opcode.TEXT ){
+thrownewIllegalArgumentException( "Only Opcode.BINARY or Opcode.TEXT are allowed" );
+ }
+
+if( continuousFrameType != null ){
+continuousFrameType = Opcode.CONTINUOUS;
+ } elseif( fin ){
+thrownewIllegalArgumentException( "There is no continious frame to continue" );
+ } else{
+continuousFrameType = op;
+ }
+
+FrameBuilderbui = newFramedataImpl1( continuousFrameType );
+try{
+bui.setPayload( buffer );
+ } catch ( InvalidDataExceptione ){
+thrownewRuntimeException( e ); // can only happen when one builds close frames(Opcode.Close)
+ }
+bui.setFin( fin );
+if( fin ){
+continuousFrameType = null;
+ } else{
+continuousFrameType = op;
+ }
+returnCollections.singletonList( (Framedata) bui );
+ }
+
 publicabstractvoidreset();
 
 publicList<ByteBuffer> createHandshake( Handshakedatahandshakedata, Roleownrole ){