Packages

t

akka.projection.grpc.producer.scaladsl

EventProducerInterceptor

trait EventProducerInterceptor extends AnyRef

Interceptor allowing for example authentication/authorization of incoming requests to consume a specific stream.

Annotations
@ApiMayChange()
Source
EventProducer.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EventProducerInterceptor
  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 asynchronously failing the returned future with a akka.grpc.GrpcServiceException