Package csw.command.client.handlers

Class CommandServiceWebsocketHandlers

java.lang.Object

msocket.impl.ServerStreamingSupport<Req,akka.http.scaladsl.model.ws.Message>

msocket.impl.ws.WebsocketHandler<CommandServiceWebsocketMessage>

csw.command.client.handlers.CommandServiceWebsocketHandlers

All Implemented Interfaces:

msocket.api.MessageHandler<CommandServiceWebsocketMessage,akka.stream.scaladsl.Source<akka.http.scaladsl.model.ws.Message,akka.NotUsed>>

public class CommandServiceWebsocketHandlers
extends msocket.impl.ws.WebsocketHandler<CommandServiceWebsocketMessage>

Constructor Summary

Constructors

Constructor	Description
CommandServiceWebsocketHandlers(csw.command.api.scaladsl.CommandService commandService, msocket.api.ContentType contentType)

Method Summary

Modifier and Type	Method	Description
akka.stream.scaladsl.Source<akka.http.scaladsl.model.ws.Message,akka.NotUsed>	handle(CommandServiceWebsocketMessage request)

Methods inherited from class msocket.impl.ServerStreamingSupport

futureAsStream, stream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CommandServiceWebsocketHandlers

public CommandServiceWebsocketHandlers(csw.command.api.scaladsl.CommandService commandService,
                                       msocket.api.ContentType contentType)

Method Detail

handle

public akka.stream.scaladsl.Source<akka.http.scaladsl.model.ws.Message,akka.NotUsed> handle(CommandServiceWebsocketMessage request)