Category "stream"

Spring Cloud Stream RabbitMQ wait for publisher confirms

I am using Spring Cloud Stream with the RabbitMQ binder. I use the StreamBridge to send messages to a destination. I want to send a message with StreamBridge an

Flutter Firestore real-time pagination using multiple listeners streamed combined

I want to create a pagination screen, using Bloc, from the Firestore database. The screen should update on document changes. My FirestoreProviderApi receives fe

How to convert ReadableStream into ReadStream in NodeJS?

I'm using nodemailer, and pdfmake to create a pdf, and send it in the email's attachments. I don't have too much experience with file handling in NodeJS, and I

java.util.Arrays.asList when used with removeIf throws UnsupportedOperationException

I am preparing for an OCPJP 8 exam for the next 2 months and currently I this one got my attention as I dont understand why public class BiPredicateTest { p

What is the best practice of streaming JSON objects in Nodejs, if it is bigger than 10M and split it into multiple streams?

I have a JSON object, it is a big object. I need to send (write) it as a Kafka message and it takes a lot of time. I need a mechanism to stream the JSON object

Pipe and OpenCV to FFmpeg with audio streaming RTMP in Python

I'm trying to stream FFmpeg with audio. I will show my code below: Import module import subprocess as sp Create variables rtmpUrl = "rtmp://a.rtmp.youtube.com

How to save MediaRecorder Web API output to disk using a stream

I am experimenting with the MediaStream Recording API within Electron (therefore Node.js) and wish to handle the output as a stream. Handling as a stream would

Node.js: can you use asynchronous functions from within streams?

Consider the following: var asyncFunction = function(data, callback) { doAsyncyThing(function(data){ // do some stuff return callback(err) }) } fs.

How to filter files in Databricks Autoloader stream

I want to set up an S3 stream using Databricks Auto Loader. I have managed to set up the stream, but my S3 bucket contains different type of JSON files. I want

How to remove an element from a Set inside a Page of items based on a Condition using Java 8

I have a Page of Farmers coming from a JPA repository call findAll method. Each Farmer consists of a Set of Farms which are also coming in the repository call l

Fetch data from firestore inside a stream map

Is it possible to let a stream await during a fetch from firestore? I want to achieve that a user also fetches his own roles from the firestore database. Of cou

Write a java program to read from a lengthy string (using streams) and write the output to a file?

How can I get a lengthy String as an input using streams and how to write the output to a file ?

Python bz2 returns EOFerror before the whole file has been read

I am trying to lazily load items from a compressed file that resides in Zenodo. My goal is to iteratively yield the items without storing the file in my compute

How to live stream a local video using FFmpeg

I am trying to get used to the FFmpeg library, and currently, I have been trying to stream local video on VLC using FFmpeg. The command I have been using is:

how to stop a stream api in callback nodejs

hi i'm using binance api, it has a stream function like below which i don't know how to stop it after the if statement is true. binance.websockets.bookTickers("

Node.js how to pipe gzip stream to writestream

I can't seem to get this to work. I want to write some data to a gzip stream and then pipe the gzip stream to a file write stream. I want to then call a functio

Drive Api - large file stream in nodejs

Drive Api - large file stream in nodejs hello , I went to stream large file from google drive to my website but I have issue that... app.get("/blog.mkv", (re

Using jq to stream, filter large json file and save output as csv

I have a very large json file I would like to stream (using --stream) and filter with jq, then save it as a csv. This is the sample data with two objects: [{"_i

Apache Flink + CEP - Detect same events

I'd like to detect events that share the same property. Suppose I have a simple case class: case class Record(name: String, value: Int) Suppose there is the

Converting a Buffer into a ReadableStream in Node.js

I have a library that takes as input a ReadableStream, but my input is just a base64 format image. I could convert the data I have in a Buffer like so: var img