event-stream

0熱度

1回答

我正在構建一個使用event-stream的節點腳本，該腳本通過split()方法逐行遍歷文件，並且我想引用結果輸出中的行號。這可能在我的實施？ ``` var s = fs.createReadStream(entry.fullPath) .pipe(es.split()) .pipe(es.mapSync(function(line) { // How can

0熱度

1回答

WSO2：在Siddhi查詢中更新輸出流

我有一個siddhi查詢，通過使用時間批量窗口在一分鐘內獲得總事件數。使用輸出流我正在更新具有常數值的條形圖，x軸上的時間戳（日期和時間，直到分鐘）以及y軸上的事件計數。但有時候，一分鐘內發生的事件數量太長而無法傳輸，因此查詢不會給出正確的結果。例如，如果我得到總共60個事件，並且此查詢首先給出了條形圖中顯示的40的計數，但是一分鐘後它將其值更改爲20，根據邏輯它是正確的，但是我擔心如果有一種

1熱度

2回答

如何讓量角器忽略特定的異步Angular任務？

我的angularJS應用程序使用事件蒸發，並保持打開http事件蒸汽請求和偵聽服務器事件。所以我的問題是當量角器開始測試我的angularJS應用程序時，它會一直等待完成事件流請求，因爲我正在使用ignoreSynchronization = false，因此量角器一直等待，直到它獲取超時，因爲事件流http請求永遠不會結束。所以我想教我的量角器忽略這樣的事件流$ http任務並繼續測試我的應用

2熱度

1回答

開發者工具 - >網絡中的奇怪的鉻行爲

我在我的網站上使用SignalR與服務器發送的事件，並且我能夠在Chrome中使用開發人員選項卡單擊該請求，然後選擇「EventStream」選項卡。但是最近發生了一些不可思議的事情，每次我用EventStream選項卡選擇請求時，選擇會在一秒鐘或兩秒後跳到下一個或上一個項目，所以我什麼都看不到。另一個奇怪的是，即使我關閉了控制檯，下次打開開發人員工具時，控制檯也會自行彈出。我不知道這些是否連接

1熱度

1回答

將數據從PHP腳本傳遞到PHP事件流

因此，我有一個PHP文件，它將隨機接收來自第三方的新發布數據。爲了簡單起見，我們把它叫做get_data.php說，它看起來是這樣的： <?php $data = $_REQUEST; // Data processing 然後，我有一個單獨的腳本，stream.php，這是使用HTML5 Server-Sent Events以數據流的（JS）客戶端： <?php header('Con

1熱度

1回答

當通過es.map（）和JSONStream.stringify（）管道JSONStream.parsed（）將文件流管道輸入流

我試圖通過JSONStream.parse管道輸入流（從巨大的GeoJSON文件創建）（）將流分解成對象，然後通過event-stream.map（）讓我轉換對象，然後通過JSONStream.stringify（）創建一個字符串，最後創建一個可寫的輸出流。隨着進程的運行，我可以看到節點的內存佔用量繼續增長，直到最終耗盡堆。下面是重現該問題的最簡單的腳本（test.js）：即噴出JSON源源不斷

0熱度

1回答

的NodeJS服務器端的事件只是不想上班

我一直在試圖弄清楚這一點了好幾個小時...... 我用它解釋各種教程，複製代碼到我的代碼，但它只是沒有按沒有工作。沒有錯誤信息，沒有。下面是我在做什麼：客戶端： <script> startStream() function startStream() { source = new EventSource("/stream") if(typeof(EventSourc

0熱度

1回答

有什麼辦法可以使用java SSE客戶端獲取Hystrix流

有沒有什麼辦法可以獲取Hystrix流（它會產生矩陣），因爲它是服務器端的事件流，因此無法使用普通的http客戶。我正在嘗試使用基於Jersey的SSE，但它無法這樣做。每當hystrix進行調用時，它都會生成一些可以通過servlet訪問的度量數據（示例url爲::/hystrix.stream）。我想捕獲此流在特定時間的響應。任何方式來做到這一點？謝謝。

0熱度

1回答

WSO2CEP：在siddhi查詢中從流中獲取上一個事件值

我一直在使用以下siddhi query來獲取每分鐘的事件計數; ts作爲時間戳（字符串）和ftp_requests作爲count（int）。 from FTPInStream[command == 'USER'] select time:timestampInMilliseconds(time:dateAdd(str:replaceAll(ts,'T',' '), 5, 'hour',"yyy

0熱度

1回答

關閉第一個eventsource上的第二個onopen方法

我正在使用window.EventSource將數據流式傳輸到表視圖的應用程序。由於每個服務器的最大連接數限制爲6，我想在給定的時間點有一個EventSource對象，所以從根本上來說我需要關閉第二個onopen方法上的第一個事件源對象然後第二個onmessage事件將數據流傳送到表視圖。考慮下面的代碼上的onclick事件運行， if(firstEventSource) { first