开发者社区

文档建议反馈控制台

文章/答案/技术大牛

发布

社区首页 >问答首页 >如何在Java中向Source.actorRef或Source.queue发送元素

问如何在Java中向Source.actorRef或Source.queue发送元素
EN

Stack Overflow用户

提问于 2017-11-16 02:44:02

回答 1查看 1.1K关注 0票数 1

我目前正在为一个个人项目使用Akka (用Java语言)，我很难理解如何将元素发送到Source。

其想法是使用WebSocket将内容推送到用户的web浏览器中。我已经按照Akka HTTP文档成功地使用Akka流创建了一个请求响应系统，但这不是我想要做的。

查看Akka文档，我看到了Source.queue和Source.actorRef。但我不明白如何将一个元素放入Source中。Source.queue和Source.actorRef返回一个Source，它没有方法offer (对于Source.queue)或tell (对于Source.actorRef)。

我的问题是:如何使ActorRef用于Source.actorRef创建的Source，或者如何使SourceQueueWithComplete用于使用Source.queue创建的Source，以便能够将元素发送到Source

我搜索了各种Akka文档，但没有找到这样做的方法。我在互联网上找到的大部分代码都是用Scala编写的，这似乎没有同样的问题。

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2017-11-16 03:12:57

来自Source.actorRef和Source.queue的参与者和队列分别是这些源的物化值，这意味着只有当流运行时才能获得它们。例如：

final ActorRef actor =
  Source.actorRef(Integer.MAX_VALUE, OverflowStrategy.fail())
        .to(Sink.foreach(m -> System.out.println(m)))
        .run(materializer);

actor.tell("do something", ActorRef.noSender());

在Scala中没有什么不同：

implicit val materializer = ActorMaterializer()

val actor =
  Source.actorRef(Int.MaxValue, OverflowStrategy.fail)
        .to(Sink.foreach(println))
        .run()

actor ! "do something"

票数 2

EN

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/47327565

复制

相关文章

5.1 汇编语言：汇编语言概述

汇编语言是一种面向机器的低级语言，用于编写计算机程序。汇编语言与计算机机器语言非常接近，汇编语言程序可以使用符号、助记符等来代替机器语言的二进制码，但最终会被汇编器编译成计算机可执行的机器码。

微软技术分享

2023/08/22

4160

5.1 汇编语言：汇编语言概述

汇编语言变量计算机数据字符串

汇编语言是一种面向机器的低级语言，用于编写计算机程序。汇编语言与计算机机器语言非常接近，汇编语言程序可以使用符号、助记符等来代替机器语言的二进制码，但最终会被汇编器编译成计算机可执行的机器码。

微软技术分享

2023/10/11

6390

代码还原,IDA中使用的宏

如果想使用,直接去IDA的plugins插件目录下.包含它的 **defs.h"" 如下:

IBinary

2019/05/25

5.1K0

Sword To Offer 064 - 滑动窗口的最大值

给定一个数组和滑动窗口的大小，找出所有滑动窗口里数值的最大值。例如，如果输入数组{2,3,4,2,6,2,5,1}及滑动窗口的大小3，那么一共存在6个滑动窗口，他们的最大值分别为{4,4,6,6,6,5}；针对数组{2,3,4,2,6,2,5,1}的滑动窗口有以下6个： {[2,3,4],2,6,2,5,1}， {2,[3,4,2],6,2,5,1}， {2,3,[4,2,6],2,5,1}， {2,3,4,[2,6,2],5,1}， {2,3,4,2,[6,2,5],1}， {2,3,4,2,6,[2,5,1]}。

Reck Zhang

2021/08/11

2220

[DCC Error] E2161 Error: RLINK32: Unsupported 16bit resource in file “.dfm”

delphi 腾讯云开发者社区打包 https 网络安全

Delphi程序的郁闷之处就在于各种第三方的库处理起来太麻烦了，总是有人喜欢引入一些从来没见过的东西，于是编译的时候就变得非常蛋疼，不是库不好找而是不同的版本导致出现各种错误。比如alphacontrols这个鸟插件就测试了n个版本。其实这个不是最蛋疼的，最蛋疼的是处理完了所有的错误之后编译出现问题了：[DCC Error] E2161 Error: RLINK32: Unsupported 16bit resource in file “.dfm”

obaby

2023/02/23

5580

ubuntu 出现GPG Error的问题[通俗易懂]

ubuntu https linux apt-get bash

错误提示：gpg error the public key is not available no_pubkey 5523BF*********

全栈程序员站长

2022/11/04

1K0

使用Androidkiller或APKIDE编译APK文件时出现libpng error: Not a PNG file的错误

打包 https 网络安全 android

>W: libpng error: Not a PNG file >W: ERROR: Failure processing PNG image D:\xin\AndroidKiller_v1.3.12018\projects\CFF_100\Project\res\mipmap-xxhdpi-v4\ic_launcher.png

全栈程序员站长

2022/11/17

4.4K0

使用Androidkiller或APKIDE编译APK文件时出现libpng error: Not a PNG file的错误

Sword To Offer 037 - 数字在排序数组中出现的次数

数字在排序数组中出现的次数 Desicription 统计一个数字在排序数组中出现的次数。 Solution class Solution { public: int GetNumberOfK(const vector<int>& data ,int k) { return upper_bound(data.begin(), data.end(), k) - lower_bound(data.begin(), data.end(), k); } };

Reck Zhang

2021/08/11

2450

Sword To Offer 040 - 数组中只出现一次的数字

一个整型数组里除了两个数字之外，其他的数字都出现了两次。请写程序找出这两个只出现一次的数字。

Reck Zhang

2021/08/11

3160

Sword To Offer 028 - 数组中出现次数超过一半的数字

数组中有一个数字出现的次数超过数组长度的一半，请找出这个数字。例如输入一个长度为9的数组{1,2,3,2,2,2,5,4,2}。由于数字2在数组中出现了5次，超过数组长度的一半，因此输出2。如果不存在则输出0。

Reck Zhang

2021/08/11

2130

integer类型比较大小_pow的值的数据类型

https 网络安全 html 数据库云数据库 SQL Server

MySQL支持SQL标准整数类型 INTEGER（或 INT）和SMALLINT。作为标准的扩展，MySQL还支持整数类型 TINYINT、MEDIUMINT 和 BIGINT。下表显示了每个整数类型所需的存储和范围。.

全栈程序员站长

2022/10/29

7410

masm nasm的全局变量

asm masm nasm 语法

这样就可以在c 或其他asm中使用了 public _ghook,gvm .data _ghook: TIHooKing <> gvm: dq 0 比如：masm中语法 .data extern _gvm:dword extern SPMagiCode:dword c中语法： extern int _test; nasm中语法： .global studentID .data studentID: .word 12345678

战神伽罗

2019/07/24

1.2K0

nginx设置header如果没有值

html nginx tcp/ip http

map 指令是由 ngx_http_map_module 模块提供的，默认情况下安装 nginx 都会安装该模块。

十毛

2022/08/23

1.4K0

nginx设置header如果没有值

如何找出单向链表中每个节点之后的下个较大值?

编程算法数据结构

1. 要找到的是一个元素之后下个较大值,这里的关键词是[下个较大值]是其后第一个大于当前元素的值.如例子中,第二个元素4(list[1])对应的下个较大值应为5,而不是8.

一个架构师

2022/06/20

1.1K0

如何找出单向链表中每个节点之后的下个较大值?

制作通过 NuGet 分发的源代码包时，如果目标项目是 WPF 则会出现一些问题（探索篇，含解决方案）

wpf nuget 编译程序解决方案

在使用 NuGet 包来分发源代码时，如果目标项目是 WPF 项目，那么会有一大堆的问题。

walterlv

2023/10/22

4910

制作通过 NuGet 分发的源代码包时，如果目标项目是 WPF 则会出现一些问题（探索篇，含解决方案）

宝塔部署Django出现Internal Server Error

app file ini uwsgi wsgi

打开程序目录下的uwsgi.ini，修改wsgi-file为你的Django，app下的wsgi.py

SingYi

2022/07/14

1.7K0

宝塔部署Django出现Internal Server Error

汇编debug与masm命令

actionscript 汇编语言

汇编语言这块是我之前写在网易博客上的，不过那个账号基本已经作废了，所以现在抽个时间把当时的博客搬到CSDN上。汇编命令（编译器masm命令）：找到masm所在的文件夹，我的在d：\MASM中，用cmd打开dos界面，输入“d:”切换到D盘，再输入“d:\MASM\masm”打开编译器中的masm程序得到如下结果：

Masimaro

2019/02/25

1.5K0

Sword To Offer 034 - 第一个只出现一次的字符

在一个字符串(1<=字符串长度<=10000，全部由字母组成)中找到第一个只出现一次的字符,并返回它的位置

Reck Zhang

2021/08/11

2850

null或空值的判断处理

java 编程算法 c++打包

1，错误用法一： if (name == "") { //do something } 2，错误用法二： if (name.equals("")) { //do something } 3，错误用法三： if (！name.equals("")) { //do something } 我们来解说一下：上述错误用法1是初学者最容易犯，也最不容易被发现的错误，因为它们的语法本身没问题，Java编译器编译时不报错。但这种条件可能在运行时导致程序出现bug，永远也不会为true，也就是时说，if块里的语句永远也不会被执行。上述用法二，用法三的写法，是包括很多Java熟手也很容易犯的错误，为什么是错误的呢？也许你会感到纳闷。对，它们的写法本身没错，但是，少了一个null判断的条件，试想，如果name=null的情况下，会发生什么后果呢？后果是，你的程序将抛出NullPointerException异常，系统将被挂起，不再提供正常服务。当然，如果之前已经对name作了null判断的情况例外。正确的写法应该先加上name != null的条件，如例： if (name != null && ！name.equals("")) { //do something } 或者 if (!"".equals(name)) {//将""写在前头，这样，不管name是否为null，都不会出错。 //do something } 下面，我们举一个简单的例子： TestNullOrEmpty.java

似水的流年

2019/12/08

3.4K0

点击加载更多

相似问题

无法连接本地主机上的动物园管理员:2181

10

卡夫卡动物园管理员连接问题

316

卡夫卡和动物园管理员TLS

14

其他信息系统如何处理卡夫卡动物园管理员解决的问题？

10

卡夫卡和动物园管理员家属

10

添加站长进交流群

领取专属 10元无门槛券

AI混元助手 在线答疑

关注 腾讯云开发者公众号

洞察 腾讯核心技术

剖析业界实践案例