Observableで文字列ストリームをバッファリングする方法は？

Question

私は無限のバイナリストリームを持っています。今は10000文字ごとにバッファしたいと思っています。

theFunctionKeepsStreamingString() 
.bufferWithCount(10000) //this is not working 
.map((data）=>{ 
    //dealing with each 10000 characters 
}); 

しかし、このように動作していないようです。これはどうすればいいですか？

Answer 1

ここに問題はありません。

は Plunkrのテストを作った：

const { Observable } = Rx; 

const characters = ['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h']; 

Observable 
    .from(characters) 
    .bufferCount(3) 
    .do(console.log) 
    .subscribe(); 

そして、それは期待どおりに動作：