Re: [akka-user] Akka Websocket Strict vs non Streamed

t from there. > > It's basically as simple as > streamedData.map(_.utf8String).runWith(Sink.foreach(it => println(it))) etc. > > Hope this helps! > -- > Konrad `ktoso` Malawski > Akka <http://akka.io> @ Lightbend <http://lightbend.com> > > On 31 May 2016 at 18:2

[akka-user] Akka Websocket Strict vs non Streamed

} > } > }), (x -> BinaryMessage.create(x))); > > I'm happy for all tips, java/scala-code-snippets and so on :) Big Thanks Qux -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>&

[akka-user] Websocket Server: Actor that can send, consume and answers Messages - is this ok?

Hi, I implemented a short prove of Concept and wanted to ask if this is the right way to do it, because it doesn't feel so ;) Here the Code:

[akka-user] Tunnel httprequests/responses through websocket

Hello, I want to tunnel httprequests and responses through akka-http Websockets. Is there a simple way to convert the binarymessage (from the websocket) in a httpmessage (and vice versa)? Or is there a way to get a akka httpresponse/request from a string? Thanks for your help. --

[akka-user] Bug in akka.http.javadsl.server.directives.WebSocketDirectives?

Hi, I want to use the WebSocketDirectives in Java. Is it intended that handleWebSocketMessages needs an handler of typ Flow[Message, Message, T], but handleWebSocketMessagesForProtocol an hander of typ Flow[Message, Message, Any]? Because of that I can not use

[akka-user] Akka Stream, Framing with GraphStage instead of PushPullStage: messages get lost

eded = -1 > ctx.push(emit) > } > /* > * After having called absorbTermination() we cannot pull any more, so > if we need > * more data we will just have to give up. > */ > private def pullOrFinish(ctx: Context[ByteString]) = > if

Re: [akka-user] Akka-HTTP, Upload, Sending 2xx response before end of request was received

Thanks, works like a charm :) About the docs: I've never done this before. How can I contribute exactly, and wheres the best place for this in the docs? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

[akka-user] Akka-HTTP, Upload, Sending 2xx response before end of request was received

; Consider waiting for the request end before dispatching this response! With small files, everything is ok, so I think it has something to do with Multipart-Messages or so. Can someone help me, so that the upload works also for bigger files? Thanks, Qux import java.io.File import akka.actor.

[akka-user] Re: Akka Stream, Framing with GraphStage instead of PushPullStage: messages get lost

-1 push(out, emit) } } } } val outbound = b.add(Flow[ByteString].map(addLengthHeader)) val inbound = b.add(Flow[ByteString].via(new FrameParser)) BidiShape.fromFlows(outbound, inbound) }) Am Donnerstag, 12. Mai 2016 17:48:21 UTC+2 schrieb Johan Andrén: > > Hi Qux, > >

[akka-user] Using "Distributed Data" for caching Tokens. Delete by value with LMWMap possible?

n possible? Thanks for your help! Qux -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>

[akka-user] Akka Typed and MDC

Hi, Whats the best way to get a DiagnosticActorLogging for Typed Actors? For untyped Actors we have this: public abstract class ActorBase extends AbstractActor { protected final DiagnosticLoggingAdapter logger = Logging.getLogger(this); @Override public void

[akka-user] Akka Typed and Futures - is there a pipe-to alternative?

Hi, I have something like this: Actor.immutable[Msg]((ctx, msg) => msg match { case DoUpdate => val update: Future[Update] = other ? (GetUpdate(_)) Actor.same case Update => //... Actor.same case _ => //... Actor.same } with trait Msg case

[akka-user] Is it possible to use Akka Typed with other Dispatchers?

Hello, how can I spawn a new TypedActor with a other Dispatcher? Is this correct? Adapter.spawn(getContext(), TypedActor.greeterBehavior(), TypedActor.NAME, akka.typed.Props.empty().withDispatcherFromConfig("blocking-io-dispatcher")); Thanks -- >> Read the docs:

Re: [akka-user] AkkaTyped and Protobuf

I'm currently using akka-kryo-serialization and I don't like it so much, maybe kryo with chill or only kryo is better, but I gonna try protobuf next. Thanks for the great help :) Am Sonntag, 19. November 2017 20:39:06 UTC+1 schrieb Patrik Nordwall: > > > sön 19 nov. 2017 kl. 19:52

[akka-user] AkkaTyped and Protobuf

Hello, I wanna try AkkaTyped with protobuf and have a lots of messages like the following ones: case class Result(i:Int) -> message Result{ int i = 1; } case class Double(i: Int, actorRef: ActorRef[Result]) -> message Double{ int i =1; ??? actorRef = 2; } Is there a way how

Re: [akka-user] AkkaTyped and Protobuf

/master/src/main/scala/blog/typed/persistence/scaladsl/BlogSerializer.scala > > with proto > https://github.com/patriknw/akka-typed-blog/blob/master/src/main/protobuf/BlogPostMessages.proto > > /Patrik > > sön 19 nov. 2017 kl. 14:09 skrev Qux <angi...@gmail.com >: > >

[akka-user] Re: Help wanted: Distributed Data with akka-typed, java and Akka 2.5.10

essageAdapter(msg -> new InternalUpdateResponse()); Am Freitag, 23. Februar 2018 22:43:00 UTC+1 schrieb Qux: > > Hello > > I'll use distributed data with akka-typed and java. I wanted to upgrade > to Akka 2.5 and stumbled over following problem: > > Before I had Adapters lik

[akka-user] Help wanted: Distributed Data with akka-typed, java and Akka 2.5.10

Hello I'll use distributed data with akka-typed and java. I wanted to upgrade to Akka 2.5 and stumbled over following problem: Before I had Adapters like: ActorRef> readResponseAdapter = ctx.spawnAdapter(InternalGetResponse::new);