Package csw.command.client.handlers

Class CommandServiceHttpHandlers

  • All Implemented Interfaces:
    io.bullet.borer.compat.AkkaHttpCompat, msocket.api.codecs.BasicCodecs, msocket.api.MessageHandler<CommandServiceHttpMessage,​scala.Function1<akka.http.scaladsl.server.RequestContext,​scala.concurrent.Future<akka.http.scaladsl.server.RouteResult>>>, msocket.impl.post.ServerHttpCodecs
    public class CommandServiceHttpHandlers
extends msocket.impl.post.HttpPostHandler<CommandServiceHttpMessage>
implements msocket.impl.post.ServerHttpCodecs

    • Constructor Summary

      Constructors 
      Constructor Description
      CommandServiceHttpHandlers​(csw.command.api.scaladsl.CommandService commandService)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      io.bullet.borer.Codec<akka.Done> doneCodec()  
      scala.Function1<akka.http.scaladsl.server.RequestContext,​scala.concurrent.Future<akka.http.scaladsl.server.RouteResult>> handle​(CommandServiceHttpMessage request)  
      akka.http.scaladsl.common.JsonEntityStreamingSupport jsonStreamingSupport()  
      io.bullet.borer.Codec<akka.util.Timeout> timeoutInSecondsCodec()  

      • 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

      • Methods inherited from interface io.bullet.borer.compat.AkkaHttpCompat

        borerCborMarshaller, borerCborMarshaller$default$1, borerCborMarshaller$default$2, borerCborUnmarshaller, borerCborUnmarshaller$default$1, borerCborUnmarshaller$default$2, borerFromEntityUnmarshaller, borerFromMessageUnmarshaller, borerJsonMarshaller, borerJsonMarshaller$default$1, borerJsonMarshaller$default$2, borerJsonStreamFromMessageUnmarshaller, borerJsonStreamToEntityMarshaller, borerJsonStreamToResponseMarshaller, borerJsonUnmarshaller, borerJsonUnmarshaller$default$1, borerJsonUnmarshaller$default$2, borerMarshaller, borerMarshaller$default$1, borerMarshaller$default$2, borerMarshaller$default$3, borerMarshaller$default$4, borerStreamMarshaller, borerStreamUnmarshaller, borerToEntityMarshaller, borerToResponseMarshaller, borerUnmarshaller, borerUnmarshaller$default$1, borerUnmarshaller$default$2, borerUnmarshaller$default$3, borerUnmarshaller$default$4

      • Methods inherited from interface msocket.api.codecs.BasicCodecs

        eitherDec, eitherEnc

      • Methods inherited from interface msocket.impl.post.ServerHttpCodecs

        borerJsonStreamFromEntityUnmarshaller, msocket$impl$post$ServerHttpCodecs$_setter_$jsonStreamingSupport_$eq

    • Constructor Detail

      • CommandServiceHttpHandlers

        public CommandServiceHttpHandlers​(csw.command.api.scaladsl.CommandService commandService)

    • Method Detail

      • doneCodec

        public io.bullet.borer.Codec<akka.Done> doneCodec()
        Specified by:
        doneCodec in interface msocket.api.codecs.BasicCodecs

      • handle

        public scala.Function1<akka.http.scaladsl.server.RequestContext,​scala.concurrent.Future<akka.http.scaladsl.server.RouteResult>> handle​(CommandServiceHttpMessage request)
        Specified by:
        handle in interface msocket.api.MessageHandler<CommandServiceHttpMessage,​scala.Function1<akka.http.scaladsl.server.RequestContext,​scala.concurrent.Future<akka.http.scaladsl.server.RouteResult>>>

      • jsonStreamingSupport

        public akka.http.scaladsl.common.JsonEntityStreamingSupport jsonStreamingSupport()
        Specified by:
        jsonStreamingSupport in interface msocket.impl.post.ServerHttpCodecs

      • timeoutInSecondsCodec

        public io.bullet.borer.Codec<akka.util.Timeout> timeoutInSecondsCodec()
        Specified by:
        timeoutInSecondsCodec in interface msocket.api.codecs.BasicCodecs