FParsecを使用したチャンク解析

Question

ソケットからのように、入力をFParsecパーサーにチャンクで送信することは可能ですか？そうでない場合、これを達成するために、入力ストリームの現在の結果と解析されていない部分を取得することは可能ですか？メッセージ全体をバッファリングせずに、SocketAsyncEventArgsからの入力のチャンクを実行しようとしています。

更新

SocketAsyncEventArgsの使用に注意する理由は、CharStreamにデータを送信すると、基になるStreamへの非同期アクセスが発生する可能性があることを示すためでした。具体的には、循環バッファーを使用して、ソケットからのデータをプッシュすることを検討しています。基になるStreamに非同期でアクセスしてはならないというFParsecのドキュメントを覚えているので、チャンク解析を手動で制御することを計画していました。

最終的な質問：

1. Streamに渡されたCharStreamの下で循環バッファを使用できますか？
2. このシナリオでチャンクを手動で制御することを心配する必要はありませんか？

Answer 1

FParsecの通常のバージョン（ただし、低-信頼バージョン）は、 CharStreamドキュメント。したがって、CharStreamからSystem.IO.Streamを構築し、コンテンツが複数のCharStreamブロックにまたがるのに十分な大きさである場合、入力を完全に取得する前に解析を開始できます。

ただし、CharStreamは、固定（ただし構成可能）サイズのチャンクで入力ストリームを消費することに注意してください。つまり、完全なブロックを埋めるために必要な頻度で、ReadのSystem.IO.Streamメソッドを呼び出します。したがって、新しい入力を取得するよりも速く入力を解析すると、完全なブロックを満たすのに十分な入力がまだないため、解析されていない入力がすでにある場合でも、CharStreamがブロックされる可能性があります。

更新

最終的な質問への回答： 42。

• Streamを構築するためのCharStreamをどのように実装するかは完全にあなた次第です。並列アクセスを除外するという覚えている制限は、ジェネラコディセタグコードクラスにのみ適用され、スレッドセーフではありません。

• CharStreamを循環バッファーとして実装すると、バックトラックできる最大距離を制限します。

• Streamのブロックサイズは、CharStreamがシークをサポートしていない場合にバックトラックできる距離に影響します。

• 入力を非同期に解析する最も簡単な方法は、非同期タスク（つまり、バックグラウンドスレッド）で解析を行うことです。このタスクでは、単にソケットを同期的に読み取ることができます。または、OSによるバッファリングを信頼できない場合は、以下の2番目のコメントでリンクした記事で説明されているStreamのようなストリームクラスを使用できます。

• 入力を独立したチャンクに簡単に分割できる場合（たとえば、行ベースのテキスト形式の行）、自分でチャンク化してから、入力チャンクをチャンクごとに解析する方が効率的です。