stream

1熱

1答えて

興味深い問題が出てきました。一口にこのタスクを呼び出すとき： gulp.task("cssReload",function() { browserSync.stream(); }); それは動作しません。ただし、私が電話した場合： gulp.task("cssReload",function() { gulp.src("") .pipe(browserSy

0熱

3答えて

ストリームからファイルから単語を読む

ファイルの単語をストリームに読み込もうとしていて、単語 "the"がファイルに現れる回数を数えようとしています。私はストリームだけでこれを行う効率的な方法を理解していないようです。例：ファイルに「川の上に飛び込んだ」というような文が含まれていた場合。出力は、これは私がこれまで試した public static void main(String[] args){ String file

0熱

1答えて

Apache Flink writeAsCsv（）メソッドを使ってオブジェクトのタプルを書く

私はApache Flinkチュートリアルに従ってTaxiRideイベントのストリームを整理しています。結果のストリームはコンソールに出力されます。そして今、私はcsvファイルに書きたいと思います。私はそれはコンパイルエラーにつながるDataSet<Tuple1<TaxiRide>> rides1 = filteredRides.writeAsCsv("/resources").setParall

1熱

2答えて

ネストされたリスト内の要素を最もうまく見つけるには？

Kotlinは、ストリームに似たプログラミングを可能にする便利な拡張機能を提供しています。例えば、私は、リスト内の要素を探している場合、私はfindを使用することができます。 return list.find { n -> n>4 && n<6 } しかし、私は入れ子になっているのリストを持っている場合、これは私のために実用的ではないようです。それは私foは思わ private fun fi

1熱

2答えて

WCFがストリームを返すときにクライアントが終了しました

現在、WCFサービスとC＃基本Winformアプリケーションで再生しています。どちらも別のサーバーにあります。私は、C＃アプリケーションがWCFを使用して他のサーバーからファイルを取得しようとしています。ここではWCFのコードだ： public Stream GetData(string fileName) { string filePath; FileStream file

0熱

1答えて

Javaのソケットとストリーム

私はクライアント/サーバーアプリケーションをビルドしており、2つはソケットとストリームを介して通信しています。私のサーバーは、これらのストリームを作成： this.out = new DataOutputStream(sock.getOutputStream()); this.in = new DataInputStream(sock.getInputStream()); this.bufr

2熱

2答えて

Webサービスの戻り値がオプションであり、noSuchElementExceptionを回避するかどうかを確認するために高次関数のみを使用する方法

コンテキスト：私はmenbersで家族を返すWebサービスを持っています。家族には常に父親と母親、子供はいないか複数の子どもがいます。サービスはwsdlによって以下に説明されています。目的：Java 8のOptionalを効果的に使用し、nullをチェックする古典的な方法を避けたい。私はWebサービスは常に、これは十分だろう、家族が返されると仮定すると、古典的なことで、私たちはJava 7まで

1熱

1答えて

なぜ複数のストリームを反復処理するのが最初の要素に対してのみ反復処理を行うのですか？

私は最近、複数のストリームを反復処理することで、最初のアイテムだけを反復するという、自分のコードのバグに遭遇しました。ストリームをバッファに変換しました（呼び出す関数の実装がストリームを返すことに気づいていなかった）問題が修正されました。私は信じて、このハード見つかったので、私は最小の検証例を作成した： def f(as: Seq[String], bs: Seq[String]): Unit =

0熱

1答えて

Nodejsで多重ストリームを扱うには？

私は、画像操作サービスを書いていますし、私は複数のサイズ const writable1 = storage(name1).writableStream(); const writable2 = storage(name2).writableStream(); const writable3 = storage(name3).writableStream(); //piping the f

2熱

1答えて

Python gRPCでストリーミングメッセージを処理するにはどうすればいいですか

私はこれに続くRoute_Guide sampleです。このサンプルは、特定のメッセージに返信せずにメッセージを読み取り、読み取ります。後者は私が達成しようとしているものです。が、ここで私がこれまで持っているものです。 import grpc ... channel = grpc.insecure_channel(conn_str) try: grpc.channel_rea