PipsqueakH

should rust be abandoned for fix protocol?

12

hi, @jbendig the current status of fix-rs is suspended, as " long compile times, poor networking libraries, and difficulty eliminating allocations while remaining ergonomic." actually, i am looking for some...

tell(!)方法的sender与陷阱

1

在 ``` actor ! msg ``` 中，tell 方法的签名是 ``` def !(message: Any)(implicit sender: ActorRef = Actor.noSender): Unit final def tell(msg: Any, sender: ActorRef): Unit = this.!(msg)(sender) ``` 这里的Actor.noSender的定义为 ``` /**...

Kill 不起作用？

2

Akka的文档里有 You can kill an actor by sending a Kill message. This will cause the actor to throw a ActorKilledException, triggering a failure. The actor will suspend operation and its...

Akka-http如何构造http POST request

3

Akka-http的文档略显简略，貌似对很多细节问题都没有太多探讨和示例代码。 具体问题是 对如下请求如何构造HttpRequest？ ``` curl -X POST --header 'Content-Type: application/x-www-form-urlencoded' --header 'Accept: application/json' -d 'field1=1field2=2' 'http://192.168.100.1/test' ``` 尝试了 ``` HttpRequest(method= HttpMethods.POST, uri = http://192.168.100.1/test, entity = FormData("field1"->1, "field2"->2).toEntity) ``` 但不知道问题在哪里。...

sender在Future回调中会变成dead-letters?

1

考虑这样一个Receive方法 ``` def f: Future[_] def receive: Receive = { case Msg => println("sender is " + sender) f onComplete{ case Success(_) => println("sender is " + sender) case Failure(_)...

一个Actor内部消息处理用Future还是piepTo(self)？

5

一个Actor对一个消息进行一连串的处理，中间都是Future,是一个不断的对这些Future进行map操作还是把这些Future pipeTo(self)? 例如可以这样 1： ``` def f(a: A): Future[B] def f(b: B): Future[C] def receive: Receive { case object => case a: Future[A] => a map f map g onComplete...