object EventProducer
The event producer implementation that can be included a gRPC route in an Akka HTTP server.
- Source
- EventProducer.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- EventProducer
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Value Members
- def grpcServiceHandler(system: ActorSystem[_], sources: Set[EventProducerSource], interceptor: Optional[EventProducerInterceptor]): Function[HttpRequest, CompletionStage[HttpResponse]]
The gRPC route that can be included in an Akka HTTP server.
The gRPC route that can be included in an Akka HTTP server.
- sources
All sources that should be available from this event producer
- interceptor
An optional request interceptor applied to each request to the service
- def grpcServiceHandler(system: ActorSystem[_], sources: Set[EventProducerSource]): Function[HttpRequest, CompletionStage[HttpResponse]]
The gRPC route that can be included in an Akka HTTP server.
The gRPC route that can be included in an Akka HTTP server.
- sources
All sources that should be available from this event producer
- def grpcServiceHandler(system: ActorSystem[_], source: EventProducerSource): Function[HttpRequest, CompletionStage[HttpResponse]]
The gRPC route that can be included in an Akka HTTP server.
The gRPC route that can be included in an Akka HTTP server.
- source
The source that should be available from this event producer