Questions tagged [stream]
DO NOT USE FOR THE JAVA STREAM API INTRODUCED IN JAVA 8 (use [java-stream] for those questions!) A stream is a series of data elements which can be accessed in a serial fashion.
14,909
questions
0
votes
0
answers
7
views
how to handle http response streamly by vertx http client?
@Slf4j
public class DownloadImg {
private final WebClient webClient;
private final Vertx vertx;
public DownloadImg(Vertx vertx) {
WebClientOptions newOptions = new ...
-2
votes
1
answer
35
views
How to sort using streams? [closed]
return events.stream()
.sorted(Comparator.comparing(Event::getMajorVersion).thenComparing(Event::getMinorVersion))
.collect(Collectors.groupingBy(Event::getId, Collectors.toMap(cae -&...
2
votes
1
answer
23
views
Override NetworkStream.BeginRead to get NetworkStream.ReadAsync overridden
I want to implement a network client that handles some specific protocol. The easiest option I see is to write NetworkStream descendant class that processes protocol-specific features. So I created ...
0
votes
0
answers
17
views
Save file on server drive from api call
I have a APi , that returns a file.
I wrote a piece of code to write the file and save it. But I get this Error on line 8
"- $exception {"The input is not a valid Base-64 string as it ...
0
votes
0
answers
32
views
Java ParallelStream with Spring Data JPA
I'm trying to use Java's parallel streams to retrieve records form postgres using Spring Data JPA. If I use the non parallel stream method I get the expected number of results returned. If I use the ...
0
votes
0
answers
7
views
druid-kinesis-indexing-service giving unparseable characters
I am switching our ingestion from using tranquility to use druid-kinesis-indexing-service. However, when I connect to the data it is showing lines with correct json sandwiched between unparseable ...
0
votes
0
answers
11
views
Is it possible to get AudioClip from m3u stream in Unity?
I'm trying to reproduce a stream audio in my unity app with a button in his onclick, i've already tried with some methods i found but it doesn't end the download... I post my class above:
using System....
0
votes
0
answers
15
views
Dart zip file on the fly
I'm pretty new to Dart, and I'm looking for a way to stream a zipped directory over http without saving the archive as a file.
I have looked into the Dart archive library, but I could not find a way ...
0
votes
0
answers
8
views
Join between stream-static data frame
I have an issue with spark streaming.
I have a stream df and I would like to update it
buy adding some rows from a batch df, but
when I try opération like join between the
stream Df and Batch Df | ...
0
votes
0
answers
18
views
Is it possible to grab this live surf cam and use it with a <video></video> tag?
Overview
I have a list of sourced cams by the beach to check the surf (Surfline charges for everything now).
My Problem
However, I don't have a browser that has Adobe Flash and can't find to a browser ...
1
vote
0
answers
28
views
Repairing streamed HTTP chunks in Haskell conduit
I'm streaming chess PGNs from the Lichess API. Streaming is recommended, since any given user could have up to ~500,000 games stored. The goal is to parse the PGNs in a parsePGNStream conduit as they'...
0
votes
1
answer
46
views
Why pass input/output stream in a function?
Why would we want to do this:
#include <iostream>
void print(std::ostream& os) {
os << "Hi";
}
int main() {
print(std::cout);
return 0;
}
instead of this:
#include &...
0
votes
0
answers
7
views
Sync AudioTrack in multiple device
I'm developing an app to stream an mp3 file to multiple android device within local network. My app decodes mp3 to pcm and send every decoded buffer to all connected device and then write buffer to ...
1
vote
1
answer
16
views
How to unit test that my class listen to a stream and responds correctly in Dart
Consider the following class:
enum LoginState { loggedOut, loggedIn }
class StreamListener {
final FirebaseAuth _auth;
LoginState _state = LoginState.loggedOut;
LoginState get state => ...
0
votes
0
answers
7
views
Stream Function of Arduino equivalent in Free Rtos ESP-IDF
i am trying to find an equivalent function on ESP-IDF that will be like Stream() of arduino ,
what i am trying to do is to make an MSP function to communicate with the MSP protocol with the ESPs UART, ...
0
votes
0
answers
15
views
Socket - java proxy Packets separated once send to client
I have a client Server configuration with one connection, the server cannot process the requests received in parallel, it processes them in series, to overcome this problem, we developed a proxy ...
0
votes
0
answers
23
views
print double with variable number of decimals [duplicate]
Sometimes I need double to be printed with 1 decimal (when it has the same value as integer), sometimes I need double to be printed with 6 decimals.
For example:
0.000 should be printed as 0.0
1....
0
votes
1
answer
32
views
transform map : add new key value pairs to existing map Java 8
I'm trying to transform a Map by adding a new JsonObject key-value pair, if any of the map's JsonObject's key contains the "-fragment" String.
Set<Map.Entry<String, JsonElement>> ...
0
votes
1
answer
17
views
Flutter check if stream is empty before close end
I'm using BehaviorSubject as a Stream controller.
In one of my functions, I want to .add more items only in case the Stream is empty of events.
@override
Future<void> fetchNextOverviewPolls()...
0
votes
0
answers
27
views
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 and after that synchronously wait for the ...
0
votes
1
answer
51
views
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 fetch requests from the Bloc unit. After ...
0
votes
1
answer
38
views
Chaining predicates into one using the Stream API
I have a list of predicates (List<Predicate<String>>) which I want to chain into one using or methods. How can I use the Stream API to achieve that?
0
votes
1
answer
18
views
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 and if it is bigger than 10M, split it ...
-1
votes
0
answers
27
views
How to delete contents from of a file with JAVA? [closed]
I want to delete all information of student by number.
I can read and add new student information to file. But I cannot delete student info from file. How can I solve this problem?
//For example, I ...
0
votes
0
answers
16
views
ffmpeg contentiously output stream ("multiplexing")
I play for fun with ffmpeg and try to create a cinema like stream.
The idea behind this is to have a contentiously/non ending output stream.
As input i have 2 other streams, which are shown ...
0
votes
0
answers
11
views
canvas media capture does not show up on video
I am trying to have two elements a canvas element and a video element I want the canvas element to stream to the video element but the video juts shows up empty
this is the code for the stream
...
0
votes
0
answers
16
views
Python stream Windows 10 session to remote server
I have a couple of Windows machines, and I would like to have control over those machines by having a live stream from each machine on my web server.
Is there any way to do that via Python script that ...
-1
votes
1
answer
34
views
Writing to http.ResponseWriter after defining multipart writer
I'm defining a multipart writer to stream data directly to a response writer of type http.ResponseWriter. In case of errors and for the simplicity of the example, I write the status code to w as ...
0
votes
0
answers
14
views
Guacamole session recording to stream
I managed to turn on session recording, and it is working like a charm, the only thing I would like to add is to stream those sessions(rdp and ssh) in real time.
Do you have any suggestion for me on ...
0
votes
2
answers
32
views
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 like so:
public class Farmer {
private ...
-1
votes
0
answers
17
views
Looking for material and documentation about Mongoose and MongoDB Node Driver [closed]
I'm looking for some educational material to understand how to make a mongodb cursor wrapper (as in mongoose). I would also like to better understand how the data stream works when performing a "...
0
votes
1
answer
15
views
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 course there is another alternative and the ...
0
votes
1
answer
38
views
Get the same input with EOF terminator as with .empty() function
I want to get user input, and the number of characters that are given is important. I get a satisfying result with input.empty() but it terminates after I press Enter. I want it to terminate after i ...
-1
votes
2
answers
43
views
Why I get this error : error: bad operand types for binary operator '%'?
I'm currently working on an exercise to sort only the odd element of an array of int. The program shouldn't affect the even elements, For example:
[5, 3, 8, 0, 1] --> [1, 3, 8, 0, 5]
However, when ...
1
vote
3
answers
45
views
Is there a way to turn input string to input stream in c++?
What I want to do is get user input from the terminal and use this input in other functions in my program. Since my functions only take input streams as arguments I want to convert the input string ...
0
votes
1
answer
55
views
Flutter Exception Error Creating StreamChat channel
Hello I'm trying to use StreamChat.io API to build a chat app but when I try to create a channel I get this error StreamChatNetworkError (StreamChatNetworkError(code: 1000, message: Unauthorised, ...
0
votes
1
answer
47
views
How to add unique entries of Map<String,Object> to List<Object> using Java Streams?
I have a List<Object> element in Java which contains Map<String, String> before adding a new Map<String, String> I would like to know if there is any Map in List already has that Key,...
-1
votes
0
answers
22
views
How to find the sessions time from a stream of user login events in python?
Given User Login Events continuously appearing in a stream processing system similar to this, where each line is 1 event (you can assume the pipeline is external to this program, this is a line-by-...
0
votes
0
answers
7
views
Stereo live audio streaming, different streams into left and right headphone
I wish to live stream sound from several locations and to allow the user to chose which of the offered streams will he or she be able to play in left or right ear simultaneously. So what I mean is in ...
1
vote
1
answer
35
views
Checking common element between two similar Lists using Streams
Let's say, I've 2 similar lists (not same though).
For Example: One List of Integers and another List of Hex String (which can be mapped to Integer), how can I find if there's any common element at ...
0
votes
0
answers
13
views
Processing large video files in Azure Function
I am trying to put a watermark in the video files (any size) through an Azure fucntion(C#). For the same, I am downloading the video into a Stream from an external source and then splitting it into ...
0
votes
1
answer
49
views
Java Nested filter and Nested Streams
class Item {
int id;
List<PriceDetails> priceDetails;
String itemName;
}
class PriceDetails {
int price;
}
I am getting multiple items in a JSON file. I am trying to filter ...
0
votes
0
answers
40
views
Flutter: How can I get my stream to show updated value without having to reload the page?
I have user time spent on app from firebase in seconds, I then convert it into hours, min and sec, and want to display to the user, I'm using streams but it will not update when there is a new value. ...
0
votes
0
answers
17
views
cannot stream RTSP h.265 encode in Basic4Android
i want to stream rtsp link from my camera in b4a
for h264 encoding it works fine but for h265 not working
i used multiple libraries and no luck
here is the link i use
rtsp://37.156.9.123:554/stream1?...
0
votes
1
answer
10
views
How can I clone a big stream with NodeJs?
I need to clone a RetriableReadableStream without consume it and to do this I found this way to handle it:
logo.pipe(new stream.PassThrough()) //logo is the RetriableReadableStream
This works just ...
-1
votes
0
answers
9
views
Java Streaming org.bytedeco.javacv.Frame video via UDP or RTP
I am trying to send video from webcam OpenCVFrameGrabber via UDP/RTP. How can I do it?
0
votes
0
answers
30
views
streamBuilder flutter doesn't display data
im using streamBuilder to rebuild my screen depend on the project_id selected by taping on the project widget i send project_id to the next screen with constructer the streamBuilder read that ...
0
votes
0
answers
28
views
Blazor upload file issue
I'm writing a blazor server app that will sit in the adobe marketplace
I want to upload a file through the app and place it on a server
When I call the standard code for uploading a file , I get the ...
0
votes
0
answers
18
views
How to create PyArrow Table from IOBytes stream of a JSON file from s3 bucket
import io
from pyarrow.json import read_json
import boto3
session = boto3.Session(aws_access_key_id=AWS_ACCESS_KEY_ID, aws_secret_access_key=AWS_SECRET_ACCESS_KEY)
s3 = session.resource('s3', ...
0
votes
1
answer
95
views
create json object from csv file data coming as buffer in request in node js
I'm processing csv file data coming from request to create json object using multer,csv-parser. but can't process from long time. please help and thanks.following is example of csv file processing.
...