o

akka.projection.grpc.internal.proto

EventProducerServiceHandler

object EventProducerServiceHandler

Annotations
@ApiMayChange() @AkkaGrpcGenerated()
Source
EventProducerServiceHandler.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EventProducerServiceHandler
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def apply(implementation: EventProducerService, prefix: String, eHandler: (ActorSystem) => PartialFunction[Throwable, Trailers])(implicit system: ClassicActorSystemProvider): (HttpRequest) => Future[HttpResponse]

    Creates a HttpRequest to HttpResponse handler that can be used in for example Http().bindAndHandleAsync for the generated partial function handler and ends with StatusCodes.NotFound if the request is not matching.

    Creates a HttpRequest to HttpResponse handler that can be used in for example Http().bindAndHandleAsync for the generated partial function handler and ends with StatusCodes.NotFound if the request is not matching.

    Use akka.grpc.scaladsl.ServiceHandler.concatOrNotFound with EventProducerServiceHandler.partial when combining several services.

    Registering a gRPC service under a custom prefix is not widely supported and strongly discouraged by the specification.

  5. def apply(implementation: EventProducerService, prefix: String)(implicit system: ClassicActorSystemProvider): (HttpRequest) => Future[HttpResponse]

    Creates a HttpRequest to HttpResponse handler that can be used in for example Http().bindAndHandleAsync for the generated partial function handler and ends with StatusCodes.NotFound if the request is not matching.

    Creates a HttpRequest to HttpResponse handler that can be used in for example Http().bindAndHandleAsync for the generated partial function handler and ends with StatusCodes.NotFound if the request is not matching.

    Use akka.grpc.scaladsl.ServiceHandler.concatOrNotFound with EventProducerServiceHandler.partial when combining several services.

    Registering a gRPC service under a custom prefix is not widely supported and strongly discouraged by the specification.

  6. def apply(implementation: EventProducerService, eHandler: (ActorSystem) => PartialFunction[Throwable, Trailers])(implicit system: ClassicActorSystemProvider): (HttpRequest) => Future[HttpResponse]

    Creates a HttpRequest to HttpResponse handler that can be used in for example Http().bindAndHandleAsync for the generated partial function handler and ends with StatusCodes.NotFound if the request is not matching.

    Creates a HttpRequest to HttpResponse handler that can be used in for example Http().bindAndHandleAsync for the generated partial function handler and ends with StatusCodes.NotFound if the request is not matching.

    Use akka.grpc.scaladsl.ServiceHandler.concatOrNotFound with EventProducerServiceHandler.partial when combining several services.

  7. def apply(implementation: EventProducerService)(implicit system: ClassicActorSystemProvider): (HttpRequest) => Future[HttpResponse]

    Creates a HttpRequest to HttpResponse handler that can be used in for example Http().bindAndHandleAsync for the generated partial function handler and ends with StatusCodes.NotFound if the request is not matching.

    Creates a HttpRequest to HttpResponse handler that can be used in for example Http().bindAndHandleAsync for the generated partial function handler and ends with StatusCodes.NotFound if the request is not matching.

    Use akka.grpc.scaladsl.ServiceHandler.concatOrNotFound with EventProducerServiceHandler.partial when combining several services.

  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  18. def partial(implementation: EventProducerService, prefix: String = EventProducerService.name, eHandler: (ActorSystem) => PartialFunction[Throwable, Trailers] = GrpcExceptionHandler.defaultMapper)(implicit system: ClassicActorSystemProvider): PartialFunction[HttpRequest, Future[HttpResponse]]

    Creates a partial HttpRequest to HttpResponse handler that can be combined with handlers of other services with akka.grpc.scaladsl.ServiceHandler.concatOrNotFound and then used in for example Http().bindAndHandleAsync.

    Creates a partial HttpRequest to HttpResponse handler that can be combined with handlers of other services with akka.grpc.scaladsl.ServiceHandler.concatOrNotFound and then used in for example Http().bindAndHandleAsync.

    Use EventProducerServiceHandler.apply if the server is only handling one service.

    Registering a gRPC service under a custom prefix is not widely supported and strongly discouraged by the specification.

  19. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  20. def toString(): String
    Definition Classes
    AnyRef → Any
  21. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  22. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  23. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  24. def withServerReflection(implementation: EventProducerService)(implicit system: ClassicActorSystemProvider): (HttpRequest) => Future[HttpResponse]

    Creates a HttpRequest to HttpResponse handler that can be used in for example Http().bindAndHandleAsync for the generated partial function handler.

    Creates a HttpRequest to HttpResponse handler that can be used in for example Http().bindAndHandleAsync for the generated partial function handler. The generated handler falls back to a reflection handler for EventProducerService and ends with StatusCodes.NotFound if the request is not matching.

    Use akka.grpc.scaladsl.ServiceHandler.concatOrNotFound with EventProducerServiceHandler.partial when combining several services.

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped