stream

0熱

1答えて

を入力ファイルをストリーミングするときに私は、リソースストリームとしての私の.xlsxを渡すことによって、Apacheの-POIとのxlsxワークブックオブジェクトを作成しようとしています： Workbook workbook = WorkbookFactory.create(RFQGenerator.class.getResourceAsStream("/com/lumos/xlsx_manag

0熱

1答えて

Golangスキャン機能で「ERROR：IOError：closed stream」を処理する方法は？

ノードをブートストラップするには、Golangコードでknife bootstrapコマンドを使用しています。いくつかの時間はレシピで待っており、それは10分以上待つ。そのような場合、私はエラー "エラー：IOStreamクローズ"を取得しています。時間制限を増やす方法はありますか？また、私はcmdの出力とエラーストリームからログを読んでいます。 func executeCMDWorkstatio

-1熱

1答えて

実行中のプロセスの出力へのアタッチ

プロセスはSSHセッションを介してリモートで開始されました。出力ストリーム（テキスト）はSSHでOKと表示されます。実行中のプロセスを中断することなく、結果をローカルに表示したい。実行中のプロセスに接続してストリームを「ピギーバック」する方法はありますか？ Linux専用のソリューションでも構いません。ありがとうございます！

4熱

1答えて

Akkaストリーム - 失敗した後にブロードキャストとジップでグラフを再開する

私はブロードキャストとジップの内側にフローグラフを持っています。何か（それが何であるかにかかわらず）がこの流れの中で失敗するなら、問題のある要素をそれに渡して再開したいと思います。私は印刷にそれを期待する val flow = Flow.fromGraph(GraphDSL.create() { implicit builder => import GraphDSL.Implicits.

2熱

1答えて

Node.js 15回の反復処理を行った後、読み込み可能なself.push（）が終了する

このコードのReadable = require('stream').Readableがnode.jsで15回しか動作しない理由を理解しようとしています。この行を省略すると、この行は無期限に繰り返されます。これは正しいです。 start.js console.log('Start Therm'); const thermom = require('./therm.js'); var X =

0熱

1答えて

javaオーディオファイルの場所

私はJavaでゲームをしています。オーディオファイルをInputStreamとして読み込み、そのファイルをAudioPlayerで再生するクラスがあります。ファイルが見つかりません例外が発生します。オーディオファイルをさまざまな場所に配置しようとしましたが、何も機能しませんでした。これは私のクラスのコードです： public void play(String string,int sleep

0熱

1答えて

C＃ブルーストリームストリームを確実に読み取る（InTheHand 32feet）

ブルートゥストリームを確実に読み取る際に問題があります。私がBluetooth接続で作業したのは初めてのことです。アプリケーションはBluetoothモジュールを介してArduinoと通信します。コマンドを送信して応答を得ます。例えば、応答は次のようなものになります。 1 と私は（も、それは完全に違って見える必要がある場合）、別の応答を取得する場合、私は、応答の残りの部分を取得： 100,

2熱

1答えて

カフカストリームによる単純分類

現在、私は、カフカストリームでレコードを分類するための、直接的かつ効率的な方法を探しています。すべてのレコードには、少なくともidとfailedのプロパティが含まれています。（idは単なる文字列であるとfailedはブールです）アイデアは、初めに、「メッセージ」として、すべての着信記録を分類することです。受信したレコードの1つに失敗したフィールドが設定されている場合、これはどこかに「持続」

0熱

1答えて

2つの異なるオブジェクトのリストを比較する

私は2つのオブジェクトを持っていますが、どちらも私が比較する必要がある4つの類似したフィールドがあり、それらをオブジェクトのリストとしてさまざまなソースから取得します。私は両方のリストに少なくとも1つの一致するオブジェクトがあることを確認したい。問題は、それらが異なる順序になることができるということです。私はその後、私はループ for(Object1 object1 : list1){

0熱

3答えて

apacheライブラリを持たない空白に基づいて文字列に行を分割する

バッファ付きの読者から行間を空白に基づいて文字列の配列に分割したいと思います。 BufferedReader reader = new BufferedReader(new InputStreamReader(is)); String line; 私はあなたがこれはテストのための練習であると私は任意の外部ライブラリのにはアクセスできません String[] words = StringUti