Packages

t

akka.projection.grpc.consumer.scaladsl

EventDestinationInterceptor

trait EventDestinationInterceptor extends AnyRef

Interceptor allowing for example authentication/authorization of incoming connections to a EventProducerPushDestination

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

Abstract Value Members

  1. abstract def intercept(streamId: String, requestMetadata: Metadata): Future[Done]

    Let's requests through if method returns, can fail request by throwing a akka.grpc.GrpcServiceException