WebSockets.java

    /**
     * Sends a complete binary message, invoking the callback when complete.
     * Automatically frees the pooled byte buffer when done.
     *
     * @param pooledData The buffer to be sent, it will be freed when done.
     * @param wsChannel
     * @param callback
     */
    public static void sendBinary(final PooledByteBuffer pooledData, final WebSocketChannel wsChannel, final WebSocketCallback<Void> callback) {
        sendInternal(pooledData, WebSocketFrameType.BINARY, wsChannel, callback, -1);
    }
    
    /**
     * Sends a complete binary message, invoking the callback when complete.
     * Automatically frees the pooled byte buffer when done.
     *
     * @param pooledData The buffer to be sent, it will be freed when done.
     * @param wsChannel
     * @param callback
     */
    public static void sendBinary(final PooledByteBuffer pooledData, final WebSocketChannel wsChannel, final WebSocketCallback<Void> callback, long timeoutmillis) {
        sendInternal(pooledData, WebSocketFrameType.BINARY, wsChannel, callback, timeoutmillis);
    }

    private static void sendInternal(final ByteBuffer data, WebSocketFrameType type, final WebSocketChannel wsChannel, final WebSocketCallback<Void> callback, long timeoutmillis) {
    	sendInternal(new ImmediatePooledByteBuffer(data), type, wsChannel, callback, timeoutmillis);
    }
    
    private static void sendInternal(final PooledByteBuffer pooledData, WebSocketFrameType type, final WebSocketChannel wsChannel, final WebSocketCallback<Void> callback, long timeoutmillis) {
    	boolean closeData = true;
        try {
            StreamSinkFrameChannel channel = wsChannel.send(type);
            // TODO chunk data into some MTU-like thing to control packet size
            closeData = false; // channel.send takes ownership of pooledData, so it no longer needs to be closed.
            if(!channel.send(pooledData)) {
                throw WebSocketMessages.MESSAGES.unableToSendOnNewChannel();
            }
            flushChannelAsync(wsChannel, callback, channel, null, timeoutmillis);
        } catch (IOException e) {
            if (callback != null) {
                callback.onError(wsChannel, null, e);
            } else {
                IoUtils.safeClose(wsChannel);
            }
        }finally {
        	if ( closeData ) {
        		pooledData.close();
        	}
        }
    }