AsyncWriteExt, DuplexStream}; 361 struct LinesReader { stream: DuplexStream, } impl LinesReader { fn new(stream: DuplexStream) -> Self { Self { stream } } async fn next(&mut self) -> io::Result> io::Result> { let mut bytes = Vec::new(); let mut buf = [0]; while self.stream.read(&mut buf[..]).await? != 0 { bytes.push(buf[0]); if buf[0] == b'\n' { break; } } if bytes.is_empty() { return Ok(None); にキャンセル安全性を持たせることが できます。 struct LinesReader { stream: DuplexStream, bytes: Vec, buf: [u8; 1], } impl LinesReader { fn new(stream: DuplexStream) -> Self { Self { stream, bytes: Vec::new(), buf: [0] } } async

このメソッドチェーンと非同期処理を見てNode.jsに慣れている方は Stream88 が思い浮 かぶと思います。 Stream89 を使うと、 this.lastValue のような値を保持する必要がなくなることや大きな ファイルの扱いが改善されます。 また、Promiseを使った例に比べるとより高速に処理でき る可能性が高いと思います。 streamによるread→transform→write readableStream http://nodejs.org/api/stream.html 89 http://nodejs.org/api/stream.html 98 JavaScript Promiseの本 Node.jsのStreamはEventをベースにしている技術 Node.jsのStreamについて詳しくは以下を参照して下さい。 • Node.js の Stream API で「データの流れ」を扱う方法 で「データの流れ」を扱う方法 - Block Rockin’ Codes90 • Stream2の基本91 • Node-v0.12の新機能について92 Promiseラッパー 話を戻してfs-method-chain.jsとPromise版の両者を比べると、 内部的にもかなり似てい て、同期版のものがそのまま非同期版でも使えるような気がします。 JavaScriptでは動的にメソッドを定義することもできるため、 自動的にPromise版を生成

このメソッドチェーンと非同期処理を見てNode.jsに慣れている方は Stream98 が思い浮 かぶと思います。 Stream99 を使うと、 this.lastValue のような値を保持する必要がなくなることや大きな ファイルの扱いが改善されます。 また、Promiseを使った例に比べるとより高速に処理でき る可能性が高いと思います。 streamによるread→transform→write readableStream 目的と状況にあった実装 をしていくことを考えていくべきでしょう。 Node.jsのStreamはEventをベースにしている技術 Node.jsのStreamについて詳しくは以下を参照して下さい。 • Node.js の Stream API で「データの流れ」を扱う方法 - Block Rockin’ Codes100 • Stream2の基本101 • Node-v0.12の新機能について102 98 http://nodejs.org/api/stream.html 99 http://nodejs.org/api/stream.html 100 http://jxck.hatenablog.com/entry/20111204/1322966453 101 http://www.slideshare.net/shigeki_ohtsu/stream2-kihon 102 http://www

impact at all on the diagram itself. However, those logs are printed in the command line's output stream. This could be useful for debug purpose. @startuml !function bold($text) !$result = ""+ $text "Trip Data", "PK: Medallion HackLicense VendorId; 3 TUs") AzureStreamAnalytics(streamAnalytics, "Stream Processing", "6 SUs") AzureCosmosDb(outputCosmosDb, "Output Database", "1,000 RUs") devices -->