51,988 questions
0
votes
0
answers
30
views
Losing MDC in Quarkus ManagedExecutor
I'm starting an async-process through a REST request. As soon as the REST requests returns, I'm losing the MDC context inside my async execution code. I tried to "copy" it over with ...
- 906
1
vote
0
answers
38
views
NG 21 + Vitest + Non-standalone component with async pipe
With Angular 21, I can't test (with vitest) a non-standalone component using the Async pipe. I get the following error:
X [ERROR] NG8004: No pipe found with name 'async'.
To fix this, import the "...
- 12k
-3
votes
0
answers
70
views
In UIKit, is the behavior of detached Task exactly as described in this example?
I have this code:
func drawCount() {
Task {
await _drawCount()
}
}
func _drawCount() async {
let k = await Task.detached(priority: .low) {
return gfed.filter{$0.blah}....
- 9,770
1
vote
0
answers
41
views
How do I create a lazy asset loader in bevy?
I want to load assets from a custom zip-like format, or even GoldSrc WAD3 files.
My initial attempt was to use a custom AssetLoader, but I'm not feeling comfortable having to load the entire file's ...
- 984
0
votes
1
answer
82
views
I have two simple Python functions with time.sleep and reading data so I/O-bound but I don't get expected behavior from threading and asyncio
Previously I had a question on an example of multiprocessing which you can see in the following link
I used a 2 workers pool to split a sum in a function with Python multiprocessing but the timing ...
0
votes
3
answers
81
views
why nextjs is sending async prop from a component to a suspended child component [closed]
import {Suspense} from "react"
type Props = {
params: Promise<{joblistingId: string }>
}
export default function JoblistingPage(props: Props) {
return (
<...
3
votes
0
answers
92
views
Can I modify host data after cudaMemcpyAsync
Can I modify host data in host_data_ptr after the following ?
cudaMemcpyAsync(device_data_ptr,
host_data_ptr,
size,
cudaMemcpyHostToDevice,
...
- 41
Best practices
0
votes
6
replies
130
views
Difference between await and .ConfigureAwait(true)
I understand that ConfigureAwait(false) prevents capturing the current synchronization context, allowing the continuation to run on any available thread.
However, I’m not clear about if there is any ...
-3
votes
0
answers
54
views
Async Events telemetry tracing problem because of batching of events
I'm implementing Telemetry in my Spring Boot web app using OpenTelemetry instrumentation.
All is fine except when dealing with async events.
When I produce/publish, for example 100 events - all ...
0
votes
0
answers
41
views
Making gradio to refresh itself without blocking
I have this backend:
from fastapi import FastAPI, HTTPException
import uuid
import asyncio
import random
import time
from loguru import logger
import redis
from contextlib import asynccontextmanager
#...
- 10.6k
Advice
0
votes
1
replies
53
views
Flink - Async IO Threads required
we are using Flink's AsyncIO function with Futures to make external gRPC calls. Currently, we have set the async capacity to 1, and we are using a blocking stub to make those calls. For each event, we ...
4
votes
4
answers
350
views
Task.Delay versus custom DispatcherTimer-based delay in WPF
I have a WPF project, and in some of the async event handlers in the WMain.xaml.cs I am using the Task.Delay method to suspend the execution of the handler. Example:
private async void Window_KeyDown(...
- 46.1k
Advice
1
vote
4
replies
82
views
Which paradigm and tech stack for an app that listens to messages and updates shapes on a satellite map
I am taking advantage of StackOverflow's new "General advice" question type to present my use case and ask for technical guidance.
I am a Data Scientist with several years experience in ...
- 337
0
votes
1
answer
45
views
while task inside @Async cannot be stopped with @PreDestroy in Spring Boot
I have a Problem with asynchronous methods that run on a customTaskExecutors. In the run method I never reach the last log.info that the thread is finished running (where I would usualy put other ...
- 3
-2
votes
2
answers
122
views
Waiting for coroutine to end it's job to trigger an event [closed]
I have an Activity that is responsible for creating a new entry in the database. In this activity, a button launches a coroutine to do all the database-related stuff, and when it's done, navigate to ...
-3
votes
1
answer
131
views
Console.ReadLine in a Task causing side effects [duplicate]
I want to loop and ask user if he wants to continue. If no answer for a while, loop anyway.
while (true)
{
Console.WriteLine("\nDo you want to continue? (Type 'no' or 'exit' to break, or wait ...
- 101
3
votes
0
answers
95
views
pybind11: C++ callback from background thread to Python not executed in real time
I'm trying to expose a C++ interface and callback system to Python using pybind11. In C++, everything works as expected: the callback is triggered in real time from a background thread. In Python, ...
- 83
0
votes
3
answers
121
views
Execution doesn't stop on the first await
Below code (run in: typescriptlang.org):
const sleep = async (ms: number): Promise<void> => {
return new Promise((resolve) => setTimeout(resolve, ms));
};
async function bar(x: number) {...
- 195
1
vote
0
answers
107
views
Python Asyncio: Timed out during opening handshake
I keep getting a timeout error which I can't currently explain. I'm new to networking in Python, but I can create and interact with example websocket code. For some reason the code below hits a ...
- 67
1
vote
1
answer
165
views
memcpy_async does not work with pipeline roles
If I do a memcpy_async on a per thread basis, everything works fine, see the test_memcpy32 below.
This code prefetches data within a single warp.
I want to expand this, so that I can prefetch data in ...
- 77.4k
0
votes
0
answers
54
views
When can I reliably query the preferred size of a GTK4 Entry upon
I have the following PyGObject code as an MWE:
import gi
gi.require_version("Gtk", "4.0")
from gi.repository import Gtk, GLib
class FontSizeApp(Gtk.Application):
def __init__(...
- 41
-1
votes
1
answer
80
views
Seastar: per-shard TCP listeners not binding or exiting silently on non-0 shards
I’m trying to start a per-shard TCP listener in Seastar, where each shard binds to its own port (6010 + shard_id). On shard 0, everything works — the listener binds and accepts connections fine. But ...
2
votes
1
answer
65
views
How to ensure webhook requests are routed to the same FastAPI worker that initiated the request
I’m working on a FastAPI service deployed with Uvicorn using multiple workers to handle voice communication with Twilio, and I’m running into a routing problem.
Current architecture:
A client sends a ...
2
votes
1
answer
98
views
How to execute async code for thread-locals in a non-threaded environment?
I need to execute an async function for a thread local. The minimal example:
use std::cell::RefCell;
thread_local! {
static REQUESTS_CHECKER: RefCell<()> = RefCell::new(());
}
async fn a() ...
- 5,909
-3
votes
1
answer
104
views
I apparently hit a Rust bug, what to do?
I apparently hit a Rust bug. The minimal example:
use std::cell::RefCell;
thread_local! {
static REQUESTS_CHECKER: RefCell<()> = RefCell::new(());
}
async fn a() {}
async fn b() {
...
- 5,909
0
votes
1
answer
56
views
How to handle Android UI events in C++ without blocking the main thread but keeping execution order?
I’m building an Android native application where most of the business logic resides in C++.
For example, UI events like Key Press or Drag-Drop arrive on the main thread. To process them, I forward ...
- 447
0
votes
0
answers
121
views
How can I create a single function in Rust that accepts both sync fn and async fn?
I’m building a small web server in Rust and I want the server’s add_route method to accept both synchronous and asynchronous handlers ergonomically.
Goal: allow end-users to write code as simple as:
//...
- 205
1
vote
0
answers
41
views
Resolve promise in a typescript non async function [duplicate]
I have a typescript file with the following non async function.
export function MSALInstanceFactory(): IPublicClientApplication {
const environmentService = new EnvironmentService();
const ...
- 1,108
2
votes
2
answers
96
views
Why is asyncio.gather returning results in a different order than my tasks?
I’m learning about asynchronous programming in Python and testing with asyncio.
import asyncio
import random
async def worker(name):
delay = random.randint(1, 3)
await asyncio.sleep(delay)
...
- 21
0
votes
1
answer
80
views
Spawning multiple tasks but inner function is not executed without error message
I'm trying to spawn multiple parallel (not concurrent) tasks. Every task is running a PUT operation to a custom S3 storage using AWS SDK for Rust.
The function body looks the following (the different ...
- 195
0
votes
1
answer
86
views
Get duration of a video by swift API in macOS
I'm working for weeks to get the duration of a video file. I want to use direct api calls. I know, that I can use external command line tools to get it. But I want to avoid the dependencies with these ...
- 2,324
1
vote
1
answer
92
views
Writing and running a stored procedure asynchronously *and* getting a return value
Suppose I have two stored procedures, foo and bar, both written using Snowflake Scripting language.
Inside foo, I want to call bar asynchronously and get a return value from bar. Is there currently a ...
- 1,729
0
votes
1
answer
108
views
Return timing of dart `Future` objects in asynchrounous functions
First, Please correct me anything I inferred about asynchrounous programming in dart, and even what I summarized from the docs,
And please check if my idea about when Future objects are correct. I ...
- 87
0
votes
1
answer
124
views
why am I getting "Bad state: Stream has already been listened to."?
Before asking this question, I extensively searched stackoverflow and other platforms for similar questions. However I could not find an answer to my problem.
So, basically, I am trying to use dart ...
- 3,147
0
votes
0
answers
62
views
WPF main function becomes MTA when made async
I have a WPF application and I'm trying to do some async stuff in the startup. I'm trying to move from:
[STAThread]
public static void Main(string[] args)
{
_app = new Application
{
...
- 2,465
-5
votes
1
answer
122
views
Why is arr undefined even though function returns an array? [duplicate]
const randomGIFFunc = async function(dirname) {
const dirPath = 'src/gifs/' + dirname;
fs.readdir(dirPath, (err, files) => {
if (err) {
console.log('Error reading directory: ', err );
...
- 11
0
votes
1
answer
240
views
How to run LlamaIndex ReAct agent with gpt-oss? Getting "SyntaxError: 'async for' outside async function"
I am trying to create a ReAct agent in LlamaIndex using a local gpt-oss-20b model.
I have successfully loaded my local model using HuggingFaceLLM from llama_index.llms.huggingface and it seems to be ...
- 194
0
votes
0
answers
103
views
Riverpod StateNotifier works on hot restart, but not on fresh app start
I'm building a Flutter app using Riverpod for state management. I have a SplashScreen that checks for both network connectivity and user authentication status. The SplashScreen should display ...
2
votes
1
answer
89
views
Fetch data concurrently within for loop using asnycio
I would like to optimize my current function called process_coordinates.
import asyncio
from aiohttp import ClientSession
from tqdm.asyncio import tqdm
import pandas as pd
from streetlevel import ...
- 121
0
votes
1
answer
52
views
How to show modal inside a async submit function of parent modal and wait for result
I have to paste an additional user confirmation modal box after user press Ok button in a previous message box. How to do it?
What I have as source:
export function CancelReleaseModal(props: ...
1
vote
1
answer
136
views
Unexpected thread blocking during spawned tokio file read
I'm experiencing unexpected behaviour during a file read using tokio's async I/O API.
I've optimized file reading in the following manner: Any time I read data I
await a pending join handle that ...
- 906
1
vote
1
answer
104
views
How to call an async closure multiple times [duplicate]
I am trying to get the following simple apply function to compile (simlified for example):
struct Context(i32);
pub async fn apply<F, Fut>(ctx: &mut Context, f: F)
where
F: Fn(&mut ...
- 4,156
0
votes
0
answers
92
views
How to read Boolean value from Stream as a TextReader asynchronously?
I have this code which works but is a complete mess. Is there any more efficient way to read a Boolean value from a stream asynchronously that doesn't involve checking each character in such a manual ...
- 29
0
votes
0
answers
92
views
Searching for an elegant way instead of using recalling setTimeout for Promises
I'm written an Promise class to block while async transfers json are done.
For every async transfer I call before "addwaiter", when the transfer is done I call "removewaiter".
The ...
- 11
1
vote
1
answer
141
views
Blazor not showing spinner when page loads [duplicate]
I have created a Blazor application that uses
Authentication Type = User Accounts
I have added a new menu item to the account area. This new area has a spinner that is shown until the data in that ...
- 2,350
0
votes
2
answers
114
views
Is using Google Cloud Tasks to invoke an internal Django endpoint effectively asynchronous (even under WSGI)?
I'm running a Django application on Google Cloud Run using the default WSGI-based setup (e.g., Gunicorn/ runserver for local dev).
To avoid blocking during long-running operations like third-party API ...
- 33
1
vote
0
answers
87
views
@RecordApplicationEvents (still) not working for async events
I tried to switch our application to use Async Events. Now our event publisher tests fail.
I found a few posts mentioning this https://github.com/spring-projects/spring-framework/pull/30020
So with ...
- 7,290
0
votes
1
answer
549
views
Spring AI MCP Client not interacting with MCP Server
I'm trying to implement a simple MCP Server and Client. MCP Server just has a single function to create a file
Server Implementation
@Slf4j
@Service
public class FileSystemService {
...
- 141
1
vote
1
answer
143
views
True Non threaded Asynchronous File IO in c++
How to verify if Boost.Asio actually uses Windows Overlapped I/O for file operations?
I'm implementing high-performance file I/O in C++ on Windows and need to confirm whether Boost.Asio truly ...
- 11
0
votes
0
answers
161
views
I don't understand why my test database is not being cleared and how to fix it
I'm trying to write integration tests for my FastAPI registration endpoint using SQLModel and an async PostgreSQL test database but after succesful register database don't cleaned up even i have
await ...
