stream

1熱

1答えて

htt38経由で.ndjsonファイルをロードしています。私はファイルの100行を読んだ後に閉じたいです。 const amount = 100; https.get(url, (res) => { var { statusCode } = res; if (statusCode !== 200) { throw new Error(`Request F

0熱

1答えて

スプリングインテグレーションJavaクライアントを使用したmaprsteam

私は、バンプ統合のmaprstreamを使用するソリューションを探しています。ストリームとトピックを作成することができ、ストリーム：トピックの組み合わせを使用してメッセージを消費/公開することもできました。 linkを参照してKafkaクライアントを使用しました。 Spring統合を使用してメッセージを消費/パブリッシュするのに苦労し、同じことを説明するサンプルプログラムを見ることができませんでし

2熱

1答えて

スカラにオフセット付きジェネリックtakeWhileを書く

私はtakeWhileのユースケースを持っていますが、述語がtrueの後は固定数のアイテムを保持したいところです。私はまた、コレクションのタイプに対してできるだけジェネリックであるように記述しようとしています。だから、のようなもの：それはStreamで動作するようにしたいので、 def takeWhileWithOffset[A, Iter[_] <: Iterable[A]](iter: Ite

1熱

1答えて

nodejs pipe request.postへのhttpsレスポンスと書き込みファイル

私は、http urlをチェックするHTTPプロキシプログラムを作成しています。ダウンロードリンク（content-type：octet-stream）であれば、 request.postとhttpプロキシによって与えられた応答を伴う他のコンピュータダウンロードファイルを使用してコンピュータのは、WebプロキシコンピュータはA.であり、それは（私はA.でファイルをダウンロードすることができますが

1熱

2答えて

ストリーム<Object>〜入力ストリーム

タイプ Stream<Object>をInputStreamに変換するにはどうすればよいですか？現在、私はInputStreamの先のByteArrayに変換し、それを追加するデータのすべてを反復子とループを得る： ByteArrayOutputStream bos = new ByteArrayOutputStream(); ObjectOutputStream oos = new Objec

0熱

1答えて

データベースにシリアルポートストリームをキャッチ

シリアルポートからストリーミングデータを受信するアプリケーションが残っています（産業用ウェイト）その文字列からデータを受信する必要があります。重量値のみをカットしてデータベースに送信する必要があります。私が遭遇した唯一の問題は、ラインをキャッチして重量値をカットすることでした。ここでは、私はテキストボックスのフィールドにシリアル・ストリームをキャッチするために何をすべきかです： texboxフ

0熱

1答えて

ログをSpringブートアプリケーションにストリーミングする方法はありますか？

私はイベントロガーとして使用されるSpring Bootアプリケーションを持っています。各クライアントは、REST APIを介して異なるイベントを送信し、それらはデータベースに保存されます。しかし、単純なイベントとは別に、クライアントに実行ログをSpring Bootにも送信する必要があります。クライアントが実行を終了した後にログをアップロードするのは簡単ですし、そこにたくさんの例があります。私

2熱

2答えて

ノード - 読み取り可能なストリームパイプ（）ループ

のために、私は以下のコードを複数のファイルにデータ収集をストリーミングしようとしていますで、前のストリームを上書き： for (var key in data) { // skip if collection length is 0 if (data[key].length > 0) { // Use the key and jobId to open file fo

1熱

1答えて

ノード - オーディオファイルを書き込む方法

私は、ユーザーが何を言っているのかを記録し、それをファイルに保存するアプリケーションを作成しています。マイクから音を出すために、私はnode-microphoneパッケージを使用しています。私のアプリケーションは現在、マイクからサウンドを得ることができます。しかし、ストリームをオーディオファイルに書き込んで再生しようとすると、次のエラーが発生します。 Windows Media Playerでファ

7熱

1答えて

ウィンドウの時間に関係なくApache Flinkで2つのストリームを結合する

私は結合したい2つのデータストリームを持っています。問題は、あるデータストリームが他のデータストリームよりもはるかに高い周波数を持ち、あるストリームがまったくイベントを受信しない時間があることです。 1つのストリームの最後のイベントを使用して、来るすべてのイベントで他のストリームに参加させることは可能ですか？私が見つけた唯一の解決策は、結合機能を使用することですが、結合機能を適用できる共通ウィン