ここに私がいじっているものがあります。正式ではありませんが、うまくいくようです: https://gist.github.com/cuadue/6427101
websocket からデータが入ってきたら、バッファに入れます。コールバックをポンプし (以下で説明します)、バッファを引数として送信します。"success" または "wait for more data" の戻りコードを確認してください。成功は、データが cubism に送信されたことを意味し、このコールバックを削除できます。
cubism がデータのフレームをリクエストした場合、バッファ内の最後のポイントが cubism がリクエストした最後のポイントの後にあるかどうかを確認するコールバックを設定します。それ以外の場合は、さらにデータを待ちます。
要求されたフレームの停止をカバーするデータがある場合は、この要求を満たします。履歴をリクエストする API がなければ、過去のデータを削除する必要があります。
次に、バッファをキュービズムのステップ サイズに補間します。
cubism は同じ時点のデータを複数回要求しているように見えるので、バッファをどのようにプルーニングするかはあなた次第です。要求された開始時刻よりも前にすべてのデータを削除するだけでは安全ではないと思います。