Packages

t

akka.projection.grpc.producer.javadsl

EventProducerInterceptor

trait EventProducerInterceptor extends AnyRef

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

Annotations
@ApiMayChange() @FunctionalInterface()
Source
EventProducerInterceptor.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): CompletionStage[Done]

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