腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(7564)
视频
沙龙
1
回答
Dart
超时
后
如何
取消
订阅
原始
流
?
flutter
、
dart
、
dart-stream
我有一个广播
流
,我用
超时
来
订阅
它: final s = originBroadcast.timeout(timeout, onTimeout: (sink) => sink.close()); ... } 问题是timeout()创建了另一个
流
(s),当我
取消
订阅
或出现
超时
时,它不会
取消
原始
流
(originBroadcast)。
浏览 13
提问于2021-10-05
得票数 1
1
回答
在
订阅
之前处理测试观察者的用例是什么?
rx-java
、
rx-java2
可观察类有以下方法:在
订阅
可观测对象之前,配置测试观察者的用例是什么?
浏览 1
提问于2019-09-03
得票数 1
回答已采纳
1
回答
如何
在
Dart
中使用新的Streams API执行stdin.close()?
io
、
stream
、
stdin
、
dart
、
dart-io
我要求用户在我的命令行(
dart
:io)应用程序中输入。在我得到用户的回答
后
,我想从Stream上
取消
订阅
。我认为我正在做的是关闭(读取:
取消
订阅
)转换
后
的
流
,但保持
原始
(stdin)
流
打开。 我说的对吗?如果是这样,我
如何
在程序退出时关闭底层的stdin
流
?
浏览 0
提问于2013-03-03
得票数 1
回答已采纳
1
回答
在dolphindb
取消
订阅
后
,
如何
重新
订阅
流
表?
dolphindb
在dolphindb
取消
订阅
后
,
如何
重新
订阅
流
表? 有没有办法在
取消
订阅
后
重新
订阅
流
表?我有一个场景:我
订阅
了一个
流
表,但我更改了处理程序的逻辑,因此我希望刷新处理程序函数,并从最后
订阅
的消息的偏移量重新
订阅
流
表。
浏览 18
提问于2021-06-08
得票数 0
1
回答
Dart
流
取消
订阅
dart
下面是一个简单的例子: 类发布者{ StreamController _publishCtrl =新的StreamController();
流
onPublish;Publisher
浏览 0
提问于2014-12-23
得票数 2
回答已采纳
2
回答
一个人是
如何
做到的(并且应该这样做?)是否在
Dart
中
取消
等待循环中的
流
?
dart
我有一个关于
Dart
streams的问题,如下所示。当我通过
流
的listen()方法使用它时,我可以将listen返回的结果赋给一个变量,并在完成时
取消
订阅
(比如dispose()方法)。
如何
取消
await-for循环监听的
流
? 只是为了澄清,我并不是想改变执行流程(比如,
取消
流
,以便在await-for之后运行代码),而是为了防止不再需要
流
时的内存泄漏。
浏览 2
提问于2019-08-15
得票数 3
2
回答
如何
使用托管API从EWS推送通知中
取消
订阅
exchangewebservices
、
ews-managed-api
我正在使用EWS托管API进行推送
订阅
。工作很好托管API文档说使用service.EndSubscribeToPushNotifications。
浏览 4
提问于2014-02-07
得票数 6
回答已采纳
2
回答
关于Google IoT MQTT桥的问题
mqtt
、
iot
、
google-cloud-iot
订阅
特定的主题,等待服务提供者的消息,
超时
时间为5秒。 有时5秒设备<em
浏览 0
提问于2018-04-11
得票数 1
2
回答
如何
映射()
流
,直到它在
Dart
中被
取消
?
asynchronous
、
dart
但是,一旦用户选择了一个项目,我希望
流
被
取消
。 我在写这篇文章时遇到了麻烦,因为我看不到
如何
既可以
订阅
稍后可以
取消
的
流
,又可以映射到它的元素,以便映射的
流
的使用者可以处理由
原始
Stream产生的项。基本上,我认为我需要像CancellableStream这样的东西,但我在
Dart
SDK中没有看到任何类似的东西。
浏览 29
提问于2019-02-21
得票数 2
回答已采纳
1
回答
在
Dart
流
中,Kotlin的Flow.flatMapLatest相当于什么?
kotlin
、
dart
、
kotlin-flow
、
dart-async
、
dart-stream
在Kotlin中,有一个函数: 返回一个
流
,该流在
原始
流
每次发出值时切换到由transform函数生成的新
流
。当
原始
流
发出一个新值时,由transform块产生的先前
流
被
取消
。
Dart
的Stream有等价的函数吗?
浏览 5
提问于2022-10-03
得票数 0
1
回答
我需要
取消
没有赋值给变量的StreamSubscriptions吗?
asynchronous
、
dart
、
stream
这里有两种不同的方式我可以监听一个
流
。最上面的一个没有给出关于
取消
订阅
的IDE警告。下面的是这样的。warning about cancelling subscriptionStreamSubscription s = _loginBloc.state.listen((state) {}); 如果我
浏览 1
提问于2019-04-12
得票数 0
1
回答
使用大猩猩/ websocket
订阅
websocket
go
、
websocket
我想使用的一些websocket
流
。我之所以在这里发布这篇文章,是因为我认为--这不是API的问题,而是我对websockets的一般理解--。正如描述的那样,我尝试
订阅
一个
流
:{ "method": "SUBS
浏览 5
提问于2020-07-28
得票数 3
回答已采纳
2
回答
流
服务器错误: rpc错误: code =不可用desc =传输正在关闭“
go
、
stream
、
grpc
我有一个带有gRPC
流
的服务器。在之前
订阅
了该
流
的客户端
取消
订阅
后
,我收到了此错误rpc error: code = Unavailable desc = transport is closing 在我启用了更详细的日志之后,我看到了这个警告= nil { return.... } 客户端也可以在
超时
后
调用stream.CloseSend() 服务器 GetStreamClient
浏览 1579
提问于2020-10-22
得票数 0
1
回答
使用占位符项目完成Uni,如果在截止日期之前未生产任何项目,则不
取消
处理管道
vert.x
、
reactive
、
smallrye
、
mutiny
return u.ifNoItem().after(Duration.of(10, SECONDS)).recoverWith(placeholderItem); 但是当使用这种方法时,处理流水线被
取消
是否可以在截止日期到期时使用占位符项目完成Uni,而不
取消
处理流水线?我希望即使错过了最后期限,管道也会一直进行到最后。Vert.x是可用的,如果有帮助的话。这似乎是对
原始
问题最优雅的解决方案,即
如何
在不中断处理的情况下使用虚拟项目进行响应,除非它在截止日期之前完成: Uni<Item> u = processi
浏览 17
提问于2021-04-02
得票数 0
回答已采纳
1
回答
颤振不佳状态:溪流已被聆听
android
、
flutter
、
stream
、
flutter-method-channel
但是,一旦
取消
了
流
订阅
,即使设置了
流
asBroadcastStream(),我也不能再创建新的
订阅
。Receiver.
dart
_stream ??_subscribe (
dart
:async/stream_controller.
dart
:676:7) [ ] E/flutter (32159): #1 _Co
浏览 15
提问于2022-06-28
得票数 1
回答已采纳
7
回答
Kotlin
流
:
如何
取消
订阅
/停止
kotlin
、
kotlin-coroutines
result) } listener.unsubscribe()}
原始
问题我有一个
流
发出多个字符串:suspend fun streamTest(): Flow<String> = flowViaChannel { channel ->channel.isClosedForSend) {
浏览 0
提问于2019-07-18
得票数 52
回答已采纳
2
回答
Microsoft Band 2停止用于加速度计和陀螺仪的数据
流
java
、
android
、
microsoft-band
我在可靠性测试中注意到的是,加速度计和陀螺仪在两到三分钟
后
被切断,而它们都是在中频或高频下流动的。我已经实现了一个
超时
线程,它检查最后接收到的accel或陀螺数据(取决于它们是否应该是
流
的),并在停止
流
时重新注册新的侦听器。是否有其他人有此问题和/或有人有建议,以减少电池密集的可靠的acc/陀螺仪
流
? 注册的加速度计和陀螺仪监听器在2-3分钟
后
停止接收数据。
订阅
/
取消
订阅
以及传入数据都是在
浏览 4
提问于2016-05-24
得票数 0
回答已采纳
1
回答
GRPC服务器-
流
不支持云运行中的早期客户端断开(完全管理)
google-cloud-run
我已经创建了一个GRPC服务器- Go中的流式rpc,客户端在
Dart
中。通常,在本地运行服务器时,如果客户端在服务器仍在服务
流
时提前断开连接,则
流
rpc中的context将被
取消
,服务器将停止为
流
服务。但是在云运行中,这是不一样的,当客户端断开连接时,服务器不会
取消
context。因此,除非容器达到
超时
限制,否则不会通知服务器从客户端关闭
流
。因此,如果
超时
设置为1小时,那么即使客户端提前断开连接,服务器也要计费1小时。 云运行是否需
浏览 9
提问于2020-10-14
得票数 2
回答已采纳
1
回答
如何
在使用Stream.periodic时
取消
流
?
dart
我在
取消
使用Stream.periodic构造函数创建的
流
时遇到问题。下面是我
取消
流
的尝试。但是,我很难从内部作用域中提取出'count‘变量。因此,我不能
取消
订阅
。import '
dart
:async'; int count = 0; final Stream newsStream = new Stream.periodic(
浏览 19
提问于2018-07-30
得票数 13
回答已采纳
1
回答
为什么.share()对冷源没有影响(自动连接与refCount)?
project-reactor
shared.subscribe(System.out::println);由于share()将流量转换为热流量,我预计第一个
订阅
者将获得所有值,而第二个
订阅
者将不获取任何值,因为流在
订阅
时已经完成。
浏览 0
提问于2018-05-25
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
订单超时未支付自动取消-实现简述
Spring Boot中实现订单30分钟自动取消的策略
MK甄选-2024年Flutter零基础极速入门到进阶实战[网盘高清]
带你了解大数据消息流系统Kafka
混合栈开发,AliFlutter如何解决图片问题
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券