使用Java Flow API。我有一个Processor链和一个终端Subscriber。我已经编写了Subscriber的代码，它保留了使用SubmissionPublisher时收到的项目的数量。但是，当我将值从Processor (扩展SubmissionPublisher)传递到下面的Subscriber时，不会将任何输出输出到控制台。为什么调用类变量会导致onComplete不能按预期执
浏览 19提问于2020-12-02得票数 1
回答已采纳
2回答
我开始使用Java9Flow API，我发现和不喜欢的第一件事是，当我们将订阅者实现传递给发布者时，我们似乎不能像使用RxJava那样使用lambda。
protected
浏览 0提问于2017-09-30得票数 4
回答已采纳
我的模型的工作方式如下:如果发生业务错误，它跳转到用户任务，其中管理员处理错误。我想(通过外部工具)通知客户他们的问题是
删除用户任务时省略(因为它是不可解决的)。用户任务具有消息的边界事件。以及父进程。我试着用信息关联。但是它没有任何效果，因为它没有显示任务“创建”阶段的任何消息事件订阅。
浏览 0提问于2019-01-18得票数 0
1回答
基于tcp的akka流
、、、
下面是设置:我希望能够通过tcp连接将消息(jsons转换为字节串)从发布服务器流到远程服务器订阅服务器。理想情况下，发行者将是一个参与者，它接收内部消息，对它们进行排队，如果当然有突出的需求，则将它们流到订阅服务器。我了解到，这需要扩展ActorPublisher类，以便在需要时对消息进行onNext()。
我的问题是，到目前为止，我只能够发送
浏览 2提问于2016-03-06得票数 6
我在尝试Java 9中的一些新特性，所以我做了一个测试，让一个发布者以给定的速率发出数字。我还实现了一个订阅服务器来监听这些出版物，并将它们打印到控制台。尽管我可能不完全理解如何使用这个getLastItem()，因为Api方法不打印任何内容，而Api只返回0。
唯一起作用的部分似乎是正确初始化lastItem变量的onSubscribe()。onError(Throwable t
浏览 4提问于2017-03-15得票数 5
我有一个流(A)，它以轮询为源，具有转换逻辑，并将结果数据存储在会话变量中。每当我试图在另一个流(B)中使用会话变量时。注意: Flow(B)不是从flow A调用的，我无法从中获取值。因为将无法访问会话变量。你能让我知道为什么吗？
浏览 9提问于2017-01-04得票数 0
我试图像Akka http客户端一样使用流，并在http响应中从json数组获取case类对象的Seq时遇到了麻烦。个案班：case class Foo(id: String, type: String, color: String) val req = HttpRequest(method = HttpMet
浏览 0提问于2019-01-19得票数 1
回答已采纳
1回答
为什么？
、、、
我有一个reactor.core.publisher.Mono变量，希望订阅org.reactivestreams.Subscriber，尽管它似乎不起作用。我无法理解为什么onNext方法从未调用过？，我看到onSubscribe方法被调用了。我可能弄错了，但是由于Mono实现了Publisher，订阅服务器应该可以工作。对吗？() {
System.out.println(&quo
浏览 0提问于2018-08-03得票数 1
回答已采纳
对于RxJava还是有点陌生，并试图实现一个返回可完成性的方法：@GET这就是我所说的方法：Override public void onComplete我知道这个错误：
错误:找不到适合订阅</em
浏览 1提问于2018-06-20得票数 1
回答已采纳
2回答
我有一个Android应用程序，它使用REST API来填充列表。
我正在尝试使用AsyncTask获取应用编程接口，但我在理解它的工作原理时遇到了问题。我在后台创建API对象以避免出现NetworkOnMainThreadError，但这会导致在空对象上调用我的createItems( )方法。如何在后台创建API对象，并在OnCreate过程中仍然可以使用？谢谢!下面是我的On
浏览 6提问于2017-05-22得票数 1
1回答
我是阿克卡流的学习者。我通过TCP制作了一个简单的文件服务器和一个简单的文件接收器。当服务器和接收方都在同一台主机上时，两者都能正常工作。但是，当接收方位于与服务器主机不同的主机时，接收方无法访问服务器。所以，，我的问题是，为什么不同主机的接收方不能访问服务器。例如，如果<e
浏览 1提问于2016-03-21得票数 0
回答已采纳
我有一个必须实现的java接口，如下所示：此接口必须返回一个在订阅之前一直处于不活动状态的Flow.Publisher")不幸的是，这似乎立即开始从<e
浏览 13提问于2021-09-27得票数 1
回答已采纳
我需要将flow1中的会话变量中设置的值检索到flow2。我写的代码看起来像这样： <http:listener config-ref="HTTP_Listener_Configuration" path"/>
</fl
浏览 3提问于2017-03-07得票数 0
回答已采纳
1回答
我一直在尝试如何通过API下载YouTube标题，但是官方的说明是针对命令行代码定制的，而我试图在Python中这样做。我还阅读了关于获得授权OAuth 2.0 for YouTube API的官方页面，这样我就可以自己重写这段代码了，但我无法通过以下部分：
步骤5:在web服务器接收到授权代码后，交换授权代码用于刷新和访问令牌然后，使用flow.fetch_to
浏览 0提问于2018-09-29得票数 1
我正在尝试访问本地dev环境中的strapi。由于我没有问题要与postman访问同一个url下的api，所以试图从我的节点服务器访问它时，我遇到了以下错误： at TCPConnectWrap.afterConnectaddress: '::1',
浏览 30提问于2022-10-14得票数 1
我有一个MS查询ProductDetailsAll，它使用ASP.net web服务进行查询。该服务只是将查询结果填充到数据表中。我在Flash中创建了矩形对象。每一个都必须包含产品名称、描述、价格和来自ProductDetailsAll查询
浏览 2提问于2011-02-22得票数 0
回答已采纳
我希望使用Jetty和HttpClient类从外部服务器获取内容。现在，我希望将获得的响应复制为HttpServletResponse，并返回到client (浏览器)。我试过一些东西，但没能成功。这是我的代码：
浏览 3提问于2013-05-21得票数 2
我正在将SQL 2008 R2数据库复制到SQL 2016数据库。这意味着什么，我怎样才能修好它？我使用我的Windows域用户登录，这是两个系统上的一个系统管理员。
浏览 9提问于2016-07-29得票数 3
我们的项目的RxJava订阅者是这样创建的：
不幸的是这不起作用。订阅者永远不会接到电话，我们也不会收到错误或更多的信息。但是，
浏览 2提问于2016-04-12得票数 0
回答已采纳
我对angular2类型记录和rxjs以及可观察性都很陌生。我试图使用以下代码从api获取信息 var a = Alertsanswer.subscribe，我初始化了一个私有变量："this.alerts“
在订阅之外，这个变量有未定义的值console.log(
浏览 6提问于2016-11-17得票数 4
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
