15,324 questions
0
votes
0
answers
17
views
Suspected node stream backpressure issue when piping data to tar-stream
I'm attempting to perform the following operations via a nodejs stream pipeline:
List objects under a key prefix from an object store (minio)
Read the object data for each listed object as a stream....
- 571
-1
votes
0
answers
26
views
RTSP Live Camera in Django Server or React App
I wanna stream camera live videos in my website using django and react.
in VLC -> Media -> Open Network Stream I set this RTSP url in Network tab and I can see live camera video perfectly:
rtsp:/...
0
votes
0
answers
16
views
Stream Burning in DEM [closed]
What to do if stream network generated from DEM varies drastically from what we see on basemap? how do we correct this issue?
I tried generating stream network from SRTM DEM 30m and the streams were ...
- 1
0
votes
0
answers
49
views
Which Azure Blob Storage upload method has the least memory usage and best performance for large streams?
In .NET, I have a large stream (hundreds of MB) that I’d like to directly write to Azure Blob Storage without any additional processing. My goal is to minimize memory usage while maximizing ...
- 1,068
0
votes
0
answers
47
views
Redis streams memory leak?
It is really long to explain why I use streams for simple task (and I can't change it)
but at the moment I save multiple datas into different keys which are associated with streams.
After data is got ...
- 31
0
votes
0
answers
13
views
Chat messenger reply by email next.js
I’m building a chat messenger in Next.js with Supabase as my backend. I want users to reply to chat messages directly via email, and have those replies saved in my database as new messages.
Flow ...
0
votes
0
answers
21
views
Flutter RTMP Stream Error: LateInitializationError: Field '_viewId' has not been initialized
I am trying to play an RTMP stream using the flutter_vlc_player package in my Flutter app, but I am encountering the following error when initializing the stream:
Error initializing stream: ...
- 51
1
vote
0
answers
36
views
Why can I not reuse the buffer I brought to the ReadableStreamBYOBReader?
Can someone explain the rational reading from a Web API (WHATWG) ReadableStream, using the BYOB (Bring Your Own Buffer) reader (ReadableStreamBYOBReader), why you cannot reuse your own buffer you ...
- 923
0
votes
0
answers
49
views
Building a Voice Call between Client (Browser) and Server using aioRTC - Is it Possible?
I'm working on a project where I need to establish a voice call between a client (browser) and a server. The server's primary function will be to provide LLM responses as voice output. I'm trying to ...
0
votes
2
answers
69
views
How to convert a Web API ReadableStream to a Node.js stream.Readable?
How can one convert a Web API ReadableStream (implementation of the WHATWG Streams standard) to a Node.js stream.Readable?
This is the reverse question of: How to convert a Node.js stream.Readable ...
- 923
0
votes
0
answers
16
views
Unable to create a RabbitMQ Stream with Single Active Consumer through a Python Client
Anyone have any luck creating a RabbitMQ Stream with the "Single Active Consumer" option activated with a Python Client? Tried with rstream and pika and had no luck.
We're running RabbitMQ 3....
0
votes
0
answers
27
views
How to implement StreamResponse in ASP.NET
This is ASP.NET API function to process real-time chatbot with Qwen2.5 local setup with FastAPI.
This is current code, but StreamResponse doesn't work correctly.
How to optimize this code?
[Authorize]
...
- 23
0
votes
0
answers
27
views
Issues converting child_process spawn to a Transform Stream
Im trying to convert a spawn object to a Transform stream.
The flow im doing is: downloadFileFromS3 -> decryptFileUsingCmdLine -> writeFileStream.
function createTransformStream(args) {
...
1
vote
0
answers
40
views
Unexpected behavior from c++ std::cin.get() [duplicate]
Using a book as a tutorial on C++ streams, I typed out the following code:
//include std IO header
#include <iostream>
//start here
int main()
{
int TypedLetter;
std::cout << &...
0
votes
1
answer
101
views
Efficient and Secure Handling of Large ZIP Streams in Azure Blob Storage
I need to upload a stream from the browser's network. The current approach involves uploading the stream for processing, and only if it's valid, it proceeds with the regular flow. Since the stream can ...
- 1,068
0
votes
1
answer
20
views
Duplicate Note is being added in my stream
I am creating a note taking app. A not should be added when the screen is popped. The Note is being stored in Database only once but a duplicates are being added to stream when hotrestarted the ...
5
votes
4
answers
328
views
Streaming a video from a server using ReadableSteam
Deno has this ReadableStream thing that is supposed to be compatible with the one from the browsers. https://developer.mozilla.org/en-US/docs/Web/API/ReadableStream
And it should be used when you want ...
- 67.2k
0
votes
0
answers
62
views
handle cancel grpc request stream from client with tonic
I start a grpc request with a tonic rust server. The response is a grpc stream.
The client is a web app from browser with connect-web. All is fine, I can connect the client to the server and start ...
- 933
0
votes
0
answers
71
views
Solana geyser plugin error ERR_STREAM_WRITE_AFTER_END
I am using Geyser endpoint provided by instantnodes and I have got premium service.
I am trying to subscribe to tx and following the docs of helius for yellowstone geyser usage.
async function main() {...
2
votes
0
answers
57
views
handling authentication in GO gortsplib github.com/bluenviron/gortsplib/v4
I am trying to do a rtsp live streaming POC with GO and rtsplib from github.com/bluenviron/gortsplib/v4. One thing I cannot seem to find in the docs is how to handle digest authentication.
The camera ...
- 39
1
vote
0
answers
16
views
ImageMagick Convert Pipe not working in Node
My main goal is to convert an SVG tag to PNG using Node.js and ImageMagick. I am also caching data to a Transform stream that writes to a file. I have the SVG tag ready, and when I either console.log ...
- 335
0
votes
0
answers
88
views
Infinte loop trying to read last line of InputStream
I am working on a project and am using whisper.cpp for speech to text. I am not using the Java bindings, and am instead compiling examples/stream and running it using the Process/ProcessBuilder API. I ...
- 13
5
votes
7
answers
361
views
Using Python how do I validate JSON against a JSON schema in a streaming fashion, e.g., not loading the whole object in memory?
I have a large JSON that I do not want to load into memory. I would like to validate it against a JSON schema in a streaming fashion. All libraries I could find so far, only validate completely loaded ...
- 6,512
0
votes
0
answers
27
views
AwesomeNotifications().setListeners
void main() async {
WidgetsFlutterBinding.ensureInitialized();
await AwesomeNotifications().listScheduledNotifications();
await NotificationHelper.initializeNotificationListeners();
static ...
- 31
1
vote
0
answers
30
views
Streaming chunks of data from the server using React Javascript reader seems to be blocking until the input closes
I am new to frontend programming and am given a React codebase to update.
What I want to do is to allow the user to click a button to POST some data to the backend and continuously stream data from ...
- 351
1
vote
1
answer
44
views
code":4,"StatusCode":400,"message":"WS failed with code: 4 and reason: invalid auth message format","isWSFailure":false
I used Next.js for my frontend.
I separate the token for user login authentication. I generate another token with the secret key provided by Stream.io provider to access the live stream. I'm not sure ...
0
votes
0
answers
7
views
How to view elastic search slow logs in log stream?
I enabled Slowlogs but I can't seem to find a way to view the logs. Tried looking in the log stream but I don't see anything related to the logs. Should I be able to?
Note this is an ECK deployment ...
- 1,255
1
vote
0
answers
42
views
Can Nodejs fluent-ffmpeg process opus file stream in async way?
What I want to do:
load a large opus file
processing it using fluent-ffmpeg
output a stream for further use (realtime output is required)
Runnable codes(file path needs to be changed):
const fs = ...
- 11
1
vote
0
answers
36
views
Bytes reversing and swaping in nodejs
Context
I have a file of binary logs and each log is 7 bytes.
The first 4 bytes is a timestamp (writeUInt32BE), the following 1 byte is an indicator (num 1 or 2 using writeUInt8) and the last 2 bytes ...
- 11
1
vote
1
answer
37
views
How to reset a StreamProvider when switching users in Flutter?
I’m building a Flutter app and I’m using a StreamProvider in the main.dart file to provide real-time updates about the logged-in user’s data.
However, I’m encountering an issue:
• When I log out and ...
- 15
0
votes
0
answers
15
views
Combine multiple observables based on id
Let's say I have two observables
Observable<A> with values like (1, Ametadata), (2, Ametadata)
1, 2 ... are ids and Ametadata is additional attributes of A
Observable<B> with values like (...
- 96
0
votes
0
answers
115
views
Audio-to-Text Transcription Method with ChatGPT, LiveKit, and Flutter
I’m trying to implement audio transcription generated by ChatGPT and display it in a LiveKit video with a camera, allowing the user to chat with the bot. The problem is that, at the moment, I can only ...
- 3
0
votes
0
answers
27
views
how to get the recorded stream details via api or sdk from cloudflare stream api not working
Title:
Cloudflare Stream API: 403 Forbidden When Fetching Recorded Videos for Live Input
Body:
I have created a new live stream using the Cloudflare SDK, streamed video using OBS (RTMPS), and ...
0
votes
0
answers
48
views
Java try with resources and external managed stream wrapped [duplicate]
I have code like this:
try (BufferedInputStrea stream = new BufferedInputStream(inputStream)) {
// some logic
}
servletRequest.getInputStream() is taken from HttpServletRequest object.
...
- 1,660
1
vote
2
answers
57
views
How to store a file for temporarily , process it and then delete it?
I'm trying to create a backend with nodejs/express where a file after getting uploaded it's data will be extracted by adobe api. the api needs
let readStream:fs.ReadStream | undefined = fs....
2
votes
1
answer
93
views
How to Combine Unsigned Int Into A Byte Array?
I have a couple of variables of type unsigned int that I want to combine with a byte pointer:
unsigned int a;
unsigned int b;
Byte *byte stream;
How can I combine them so that the end result is a ...
- 4,104
0
votes
1
answer
40
views
C# Blazor, ExcelDataReader Memory Stream gives Invalid Signature, FileStream does not
Trying to figure out why I am unable to read a MemoryStream using ExcelDataReader. If I hard code the path to the CSV file and pass the stream as a FileStream it works. My problem is that I am getting ...
- 105
1
vote
0
answers
73
views
Given a file created by std::ofstream using mixed int and char, if I input it back into a char buffer, can I restore the original int data?
Say I have a file created by code below:
std::unordered_map<int,int> myMap;
for ( int _ = 0; _ < 32; _++ ) {
int key = rand() % 42;
int val = rand() % 65535;
myMap.insert( std::...
- 1,290
0
votes
0
answers
24
views
Error with pdf-to-img library in TypeScript (NestJS): "esModule() is not a function"
I'm working on a NestJS project using TypeScript and trying to convert a PDF (from either a stream or a buffer) into images. I decided to use the pdf-to-img library. However, when I try to use the ...
- 83
0
votes
1
answer
585
views
Module '"ai"' has no exported member 'OpenAIStream'
I have been trying to import "OpenAIStream" and "StreamingTextResponse" from 'ai' package in next js, but I get this error:
Attempted import error: 'StreamingTextResponse' is not ...
- 405
0
votes
1
answer
126
views
How to Implement AsyncRead and AsyncWrite for a Custom AsyncUtpStream in Rust?
I am trying to implement AsyncRead and AsyncWrite traits for a custom AsyncUtpStream that wraps a UDP-based uTP-like protocol implemented using tokio::net::UdpSocket. While my underlying UDP ...
0
votes
2
answers
50
views
Java socket client-server connection. Why does the server read from the client's input and not from the output stream?
I'm really confused about how and why this example of client-server connection works.
I have two classes, NetworkClient and NetworkServer.
NetworkClient creates a socket and connects it to the server:
...
- 3
0
votes
0
answers
9
views
Error: pg_config executable not found in a dockerfile [duplicate]
I'm getting an issue with psycopg2 when I build the image on Debian machine.
I have a dockerfile:
FROM python:3.12-slim
COPY . /app
WORKDIR /app
RUN pip3 install -r requirements.txt
ENTRYPOINT [ "...
- 37
0
votes
1
answer
46
views
operator<< overload for class with multiple layers [duplicate]
I am trying to get to the point where essentially MyClass(A) << "hi " << 17 << std::endl; compiles and executes MyClass::finish() method on the accumulated stream. So far, ...
- 1,477
0
votes
0
answers
15
views
Node js, data event not triggering
Can't get this piece of code to print out 'data' into console.
const { stdin: input, stdout: output } = require('node:process');
input.on('data', chunk => console.log('data') );
input.write('Hello!...
- 11
0
votes
1
answer
31
views
Order of result of stream-cons
I have a generator for Fibonacci numbers:
(require racket/generator)
(define fib (generator ()
(define (f a b)
(yield a)
(f b (+ a b)))
(f 1 1)
...
- 19.9k
1
vote
0
answers
33
views
FFmpeg/Next.js15 How to serve converted MKV stream to MP4 stream
I am trying to serve a video stream using Next.js 15, and using FFmpeg to convert the video stream from MKV to MP4 so it can display on a majority of web browsers. I seem to be able to convert it ...
- 11
1
vote
0
answers
16
views
nodejs stdin, data event never triggers
Input data event not triggering.
server.js
const net = require('node:net');
const { stdin: input, stdout: output } = require('node:process');
const TCPServer = net.createServer().listen({port: 3000});...
- 11
0
votes
0
answers
34
views
how agora.io limit content for living stream application
we research some live stream platform such as aws, mux,agora, find agora is strong for develop living stream application, any one know how agora.io limit the content, is it allow adult content for ...
- 39
0
votes
0
answers
51
views
How to convert a CompletableFuture to a synchronous Flux stream
I'm using BedRock AI SDK of Java, the stream function is this:
default CompletableFuture<Void> converseStream(Consumer<ConverseStreamRequest.Builder> converseStreamRequest, ...
- 21